Skip navigation links
IPC contracts for Reactive transport and protocol
C F G H I N O R S T 

C

Connector<IN,OUT,INBOUND extends Inbound<IN>,OUTBOUND extends Outbound<OUT>> - Interface in reactor.ipc.connector
An IPC connector is a inbound/outbound factory sharing configuration but usually no runtime (connection...) state at the exception of shared connection pool setups.

F

from(Connector<IN, OUT, INBOUND, OUTBOUND>, BiConsumer<? super INBOUND, StreamOperations>, Function<? super OUTBOUND, ? extends StreamOutbound>) - Static method in interface reactor.ipc.stream.StreamConnector
 

G

get(CharSequence) - Method in interface reactor.ipc.stream.StreamContext
 
get(CharSequence, U) - Method in interface reactor.ipc.stream.StreamContext
 

H

has(CharSequence) - Method in interface reactor.ipc.stream.StreamContext
 

I

Inbound<IN> - Interface in reactor.ipc.connector
A Inbound is a reactive gateway for incoming data flows.
Ipc - Annotation Type in reactor.ipc.stream
Indicates a public method is a service with possible function name.
IpcDone - Annotation Type in reactor.ipc.stream
Indicates the method, which has only an RpcStreamContext parameter and void return should be called just after disconnection from the client.
IpcInit - Annotation Type in reactor.ipc.stream
Indicates the method, which has only an RpcStreamContext parameter and void return should be called just after the connection has been established.
isClosed() - Method in interface reactor.ipc.stream.StreamOutbound
 

N

neverComplete() - Method in interface reactor.ipc.connector.Outbound
Return a never completing Mono after this Outbound.then() has completed.
newBidirectional(Supplier<?>, Class<? extends API>) - Method in interface reactor.ipc.stream.StreamConnector
 
newHandler(BiFunction<? super INBOUND, ? super OUTBOUND, ? extends Publisher<Void>>) - Method in interface reactor.ipc.connector.Connector
Prepare a BiFunction IO handler that will react on a new connected state each time the returned Mono is subscribed.
newProducer(Class<? extends API>) - Method in interface reactor.ipc.stream.StreamConnector
 
newReceiver(Supplier<?>) - Method in interface reactor.ipc.stream.StreamConnector
 
newStreamSupport(Supplier<?>, Class<? extends API>, BiConsumer<? super INBOUND, StreamOperations>, Function<? super OUTBOUND, ? extends StreamOutbound>) - Method in interface reactor.ipc.stream.StreamConnector
 

O

onCancel(long, String) - Method in interface reactor.ipc.stream.StreamOperations
 
onComplete(long) - Method in interface reactor.ipc.stream.StreamOperations
 
onError(long, String) - Method in interface reactor.ipc.stream.StreamOperations
 
onError(long, Throwable) - Method in interface reactor.ipc.stream.StreamOperations
 
onNew(long, String) - Method in interface reactor.ipc.stream.StreamOperations
 
onNext(long, Object) - Method in interface reactor.ipc.stream.StreamOperations
 
onRequested(long, long) - Method in interface reactor.ipc.stream.StreamOperations
 
Outbound<OUT> - Interface in reactor.ipc.connector
A Outbound is a reactive gateway for outgoing data flows.

R

reactor.ipc.connector - package reactor.ipc.connector
 
reactor.ipc.stream - package reactor.ipc.stream
 
receive() - Method in interface reactor.ipc.connector.Inbound
Get the inbound publisher (incoming tcp traffic for instance)
remoteAPI() - Method in interface reactor.ipc.stream.StreamContext
 
remove(CharSequence) - Method in interface reactor.ipc.stream.StreamContext
 

S

send(Publisher<? extends OUT>) - Method in interface reactor.ipc.connector.Outbound
Send data to the peer, listen for any error on write and close on terminal signal (complete|error).
sendCancel(long, String) - Method in interface reactor.ipc.stream.StreamOutbound
 
sendComplete(long) - Method in interface reactor.ipc.stream.StreamOutbound
 
sendError(long, Throwable) - Method in interface reactor.ipc.stream.StreamOutbound
 
sendNew(long, String) - Method in interface reactor.ipc.stream.StreamOutbound
 
sendNext(long, Object) - Method in interface reactor.ipc.stream.StreamOutbound
 
sendRequested(long, long) - Method in interface reactor.ipc.stream.StreamOutbound
 
set(CharSequence, Object) - Method in interface reactor.ipc.stream.StreamContext
 
StreamConnector<IN,OUT,INBOUND extends Inbound<IN>,OUTBOUND extends Outbound<OUT>> - Interface in reactor.ipc.stream
A stream connector is Connector supporting reactive streams semantics.
StreamContext<T> - Interface in reactor.ipc.stream
 
StreamOperations - Interface in reactor.ipc.stream
 
StreamOutbound - Interface in reactor.ipc.stream
 
subscribe(Subscriber<? super Void>) - Method in interface reactor.ipc.connector.Outbound
Subscribe a Void subscriber to this outbound and trigger all eventual parent outbound send.

T

then() - Method in interface reactor.ipc.connector.Outbound
Obtain a Mono of pending outbound(s) write completion.
then(Publisher<Void>) - Method in interface reactor.ipc.connector.Outbound
Append a Publisher task such as a Mono and return a new Outbound to sequence further send.
C F G H I N O R S T 
Skip navigation links
IPC contracts for Reactive transport and protocol