reactor.netty.incubator.quic

Interface QuicConnection

All Superinterfaces:

Connection, Disposable, DisposableChannel

public interface QuicConnection
extends Connection

API for creating and handling streams.

Author:

Violeta Georgieva

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Disposable

Disposable.Composite, Disposable.Swap

Method Summary

Modifier and Type	Method and Description
default Mono<Void>	createStream(BiFunction<? super QuicInbound,? super QuicOutbound,? extends Publisher<Void>> streamHandler) Creates a bidirectional stream.
Mono<Void>	createStream(io.netty.incubator.codec.quic.QuicStreamType streamType, BiFunction<? super QuicInbound,? super QuicOutbound,? extends Publisher<Void>> streamHandler) Creates a stream.

Methods inherited from interface reactor.netty.Connection

addHandler, addHandler, addHandlerFirst, addHandlerFirst, addHandlerLast, addHandlerLast, as, bind, from, inbound, isPersistent, markPersistent, onDispose, onReadIdle, onTerminate, onWriteIdle, outbound, rebind, removeHandler, replaceHandler

Methods inherited from interface reactor.netty.DisposableChannel

address, channel, dispose, disposeNow, disposeNow, disposeSubscriber, isDisposed, onDispose

Method Detail

createStream

default Mono<Void> createStream(BiFunction<? super QuicInbound,? super QuicOutbound,? extends Publisher<Void>> streamHandler)

Creates a bidirectional stream. A Mono completing when the stream is created, then the provided callback is invoked. If the stream creation is not successful the returned Mono fails.

Parameters:

streamHandler - the I/O handler for the stream

Returns:

a Mono completing when the stream is created, otherwise fails

createStream

Mono<Void> createStream(io.netty.incubator.codec.quic.QuicStreamType streamType,
                        BiFunction<? super QuicInbound,? super QuicOutbound,? extends Publisher<Void>> streamHandler)

Creates a stream. A Mono completing when the stream is created, then the provided callback is invoked. If the stream creation is not successful the returned Mono fails.

Parameters:

streamType - the QuicStreamType

streamHandler - the I/O handler for the stream

Returns:

a Mono completing when the stream is created, otherwise fails