maxQueuedControlFrames is only effective for frames written with #limitControlFramesWriter(FrameWriter).
(
SerializingExecutor executor, TransportExceptionHandler exceptionHandler,
int maxQueuedControlFrames)
| 74 | * {@link #limitControlFramesWriter(FrameWriter)}. |
| 75 | */ |
| 76 | static AsyncSink sink( |
| 77 | SerializingExecutor executor, TransportExceptionHandler exceptionHandler, |
| 78 | int maxQueuedControlFrames) { |
| 79 | return new AsyncSink(executor, exceptionHandler, maxQueuedControlFrames); |
| 80 | } |
| 81 | |
| 82 | /** |
| 83 | * Sets the actual sink. It is allowed to call write / flush operations on the sink iff calling |
no outgoing calls
no test coverage detected