クラス JettyWebSocketSession

java.lang.ObjectSE
org.springframework.web.reactive.socket.adapter.AbstractWebSocketSession<org.eclipse.jetty.websocket.api.Session>
org.springframework.web.reactive.socket.adapter.JettyWebSocketSession
実装されているすべてのインターフェース:
WebSocketSession
public class JettyWebSocketSession extends AbstractWebSocketSession<org.eclipse.jetty.websocket.api.Session>
Jetty WebSocket Session に適応する Spring WebSocketSession 実装。
導入:
5.0
作成者:
Violeta Georgieva, Rossen Stoyanchev

  • コンストラクターの詳細

  • メソッドの詳細

    • isOpen

      public boolean isOpen()
      インターフェースからコピーされた説明: WebSocketSession
      基になる接続が開いているかどうか。

    • close

      public reactor.core.publisher.Mono<VoidSE> close(CloseStatus status)
      インターフェースからコピーされた説明: WebSocketSession
      指定されたステータスで WebSocket セッションを閉じます。
      パラメーター:
      status - 終了ステータス

    • closeStatus

      public reactor.core.publisher.Mono<CloseStatus> closeStatus()
      インターフェースからコピーされた説明: WebSocketSession
      セッションがローカルまたはリモートで閉じられる CloseStatus へのアクセスを提供します。セッションがステータスなしで終了した場合は、空になります。

    • receive

      public reactor.core.publisher.Flux<WebSocketMessage> receive()
      インターフェースからコピーされた説明: WebSocketSession
      受信メッセージのストリームへのアクセスを提供します。

      このストリームは、接続が閉じられたときに完了またはエラーシグナルを受け取ります。典型的な WebSocketHandler 実装では、このストリームは全体的な処理フローに組み込まれるため、接続が閉じられると処理が終了します。

      セッションの処理方法の詳細と例については、WebSocketHandler のクラスレベルのドキュメントとリファレンスを参照してください。

      次で指定:
      インターフェース WebSocketSession の receive 
      次で指定:
      クラス AbstractWebSocketSession<org.eclipse.jetty.websocket.api.Session> の receive 

    • send

      public reactor.core.publisher.Mono<VoidSE> send(Publisher<WebSocketMessage> messages)
      インターフェースからコピーされた説明: WebSocketSession
      発信メッセージのソースを提供し、メッセージを書き込み、ソースが完了して書き込みが完了すると完了する Mono<Void> を返します。

      セッションの処理方法の詳細と例については、WebSocketHandler のクラスレベルのドキュメントとリファレンスを参照してください。

      次で指定:
      インターフェース WebSocketSession の send 
      次で指定:
      クラス AbstractWebSocketSession<org.eclipse.jetty.websocket.api.Session> の send 

    • sendMessage

      protected reactor.core.publisher.Mono<VoidSE> sendMessage(WebSocketMessage message)