下面列出了io.reactivex.netty.channel.ObservableConnection#writeAndFlush ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。
@Override
public Observable<Void> handle(ObservableConnection<String, String> connection) {
return connection.writeAndFlush(SERVER_MESSAGE);
}
@Override
public Observable<Void> handle(ObservableConnection<TextWebSocketFrame, TextWebSocketFrame> newConnection) {
return newConnection.writeAndFlush(new TextWebSocketFrame(SERVER_MESSAGE));
}