io.rsocket

Class RSocketFactory.ClientRSocketFactory

java.lang.Object

io.rsocket.RSocketFactory.ClientRSocketFactory

All Implemented Interfaces:

RSocketFactory.ClientTransportAcceptor

Enclosing class:

RSocketFactory

public static class RSocketFactory.ClientRSocketFactory
extends Object
implements RSocketFactory.ClientTransportAcceptor

Constructor Summary

Constructors

Constructor and Description
ClientRSocketFactory()

Method Summary

Modifier and Type	Method and Description
RSocketFactory.ClientTransportAcceptor	acceptor(BiFunction<ConnectionSetupPayload,RSocket,RSocket> biAcceptor)
RSocketFactory.ClientTransportAcceptor	acceptor(Function<RSocket,RSocket> acceptor)
RSocketFactory.ClientTransportAcceptor	acceptor(Supplier<Function<RSocket,RSocket>> acceptor)
RSocketFactory.ClientRSocketFactory	addClientPlugin(RSocketInterceptor interceptor) Deprecated.
RSocketFactory.ClientRSocketFactory	addConnectionPlugin(DuplexConnectionInterceptor interceptor)
RSocketFactory.ClientRSocketFactory	addRequesterPlugin(RSocketInterceptor interceptor)
RSocketFactory.ClientRSocketFactory	addResponderPlugin(RSocketInterceptor interceptor)
RSocketFactory.ClientRSocketFactory	addServerPlugin(RSocketInterceptor interceptor) Deprecated.
RSocketFactory.ClientRSocketFactory	byteBufAllocator(ByteBufAllocator allocator)
RSocketFactory.ClientRSocketFactory	dataMimeType(String dataMimeType)
RSocketFactory.ClientRSocketFactory	errorConsumer(Consumer<Throwable> errorConsumer)
RSocketFactory.ClientRSocketFactory	fragment(int mtu)
RSocketFactory.ClientRSocketFactory	frameDecoder(PayloadDecoder payloadDecoder)
RSocketFactory.ClientRSocketFactory	keepAlive() Deprecated.
RSocketFactory.ClientRSocketFactory	keepAlive(Duration tickPeriod, Duration ackTimeout, int missedAcks)
RSocketFactory.ClientRSocketFactory	keepAliveAckTimeout(Duration ackTimeout)
RSocketFactory.ClientRSocketFactory	keepAliveMissedAcks(int missedAcks)
RSocketFactory.ClientRSocketFactory	keepAliveTickPeriod(Duration tickPeriod)
RSocketFactory.ClientRSocketFactory	lease()
RSocketFactory.ClientRSocketFactory	lease(Supplier<Leases<? extends LeaseStats>> leasesSupplier)
RSocketFactory.ClientRSocketFactory	metadataMimeType(String metadataMimeType)
RSocketFactory.ClientRSocketFactory	mimeType(String metadataMimeType, String dataMimeType)
RSocketFactory.ClientRSocketFactory	resume()
RSocketFactory.ClientRSocketFactory	resumeCleanupOnKeepAlive()
RSocketFactory.ClientRSocketFactory	resumeSessionDuration(Duration sessionDuration)
RSocketFactory.ClientRSocketFactory	resumeStore(Function<? super ByteBuf,? extends ResumableFramesStore> resumeStoreFactory)
RSocketFactory.ClientRSocketFactory	resumeStrategy(Supplier<ResumeStrategy> resumeStrategy)
RSocketFactory.ClientRSocketFactory	resumeStreamTimeout(Duration resumeStreamTimeout)
RSocketFactory.ClientRSocketFactory	resumeToken(Supplier<ByteBuf> resumeTokenSupplier)
RSocketFactory.ClientRSocketFactory	setupPayload(Payload payload)
RSocketFactory.ClientRSocketFactory	singleSubscriberRequester()
RSocketFactory.Start<RSocket>	transport(Supplier<ClientTransport> transportClient)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.rsocket.RSocketFactory.ClientTransportAcceptor

transport

Constructor Detail

ClientRSocketFactory

public ClientRSocketFactory()

Method Detail

byteBufAllocator

public RSocketFactory.ClientRSocketFactory byteBufAllocator(ByteBufAllocator allocator)

addConnectionPlugin

public RSocketFactory.ClientRSocketFactory addConnectionPlugin(DuplexConnectionInterceptor interceptor)

addClientPlugin

@Deprecated
public RSocketFactory.ClientRSocketFactory addClientPlugin(RSocketInterceptor interceptor)

Deprecated.

Deprecated. Use addRequesterPlugin(RSocketInterceptor) instead

addRequesterPlugin

public RSocketFactory.ClientRSocketFactory addRequesterPlugin(RSocketInterceptor interceptor)

addServerPlugin

@Deprecated
public RSocketFactory.ClientRSocketFactory addServerPlugin(RSocketInterceptor interceptor)

Deprecated.

Deprecated. Use addResponderPlugin(RSocketInterceptor) instead

addResponderPlugin

public RSocketFactory.ClientRSocketFactory addResponderPlugin(RSocketInterceptor interceptor)

keepAlive

@Deprecated
public RSocketFactory.ClientRSocketFactory keepAlive()

Deprecated.

Deprecated as Keep-Alive is not optional according to spec

Returns:

this ClientRSocketFactory

keepAlive

public RSocketFactory.ClientRSocketFactory keepAlive(Duration tickPeriod,
                                                     Duration ackTimeout,
                                                     int missedAcks)

keepAliveTickPeriod

public RSocketFactory.ClientRSocketFactory keepAliveTickPeriod(Duration tickPeriod)

keepAliveAckTimeout

public RSocketFactory.ClientRSocketFactory keepAliveAckTimeout(Duration ackTimeout)

keepAliveMissedAcks

public RSocketFactory.ClientRSocketFactory keepAliveMissedAcks(int missedAcks)

mimeType

public RSocketFactory.ClientRSocketFactory mimeType(String metadataMimeType,
                                                    String dataMimeType)

dataMimeType

public RSocketFactory.ClientRSocketFactory dataMimeType(String dataMimeType)

metadataMimeType

public RSocketFactory.ClientRSocketFactory metadataMimeType(String metadataMimeType)

lease

public RSocketFactory.ClientRSocketFactory lease(Supplier<Leases<? extends LeaseStats>> leasesSupplier)

lease

public RSocketFactory.ClientRSocketFactory lease()

singleSubscriberRequester

public RSocketFactory.ClientRSocketFactory singleSubscriberRequester()

resume

public RSocketFactory.ClientRSocketFactory resume()

resumeToken

public RSocketFactory.ClientRSocketFactory resumeToken(Supplier<ByteBuf> resumeTokenSupplier)

resumeStore

public RSocketFactory.ClientRSocketFactory resumeStore(Function<? super ByteBuf,? extends ResumableFramesStore> resumeStoreFactory)

resumeSessionDuration

public RSocketFactory.ClientRSocketFactory resumeSessionDuration(Duration sessionDuration)

resumeStreamTimeout

public RSocketFactory.ClientRSocketFactory resumeStreamTimeout(Duration resumeStreamTimeout)

resumeStrategy

public RSocketFactory.ClientRSocketFactory resumeStrategy(Supplier<ResumeStrategy> resumeStrategy)

resumeCleanupOnKeepAlive

public RSocketFactory.ClientRSocketFactory resumeCleanupOnKeepAlive()

transport

public RSocketFactory.Start<RSocket> transport(Supplier<ClientTransport> transportClient)

Specified by:

transport in interface RSocketFactory.ClientTransportAcceptor

acceptor

public RSocketFactory.ClientTransportAcceptor acceptor(Function<RSocket,RSocket> acceptor)

acceptor

public RSocketFactory.ClientTransportAcceptor acceptor(Supplier<Function<RSocket,RSocket>> acceptor)

acceptor

public RSocketFactory.ClientTransportAcceptor acceptor(BiFunction<ConnectionSetupPayload,RSocket,RSocket> biAcceptor)

fragment

public RSocketFactory.ClientRSocketFactory fragment(int mtu)

errorConsumer

public RSocketFactory.ClientRSocketFactory errorConsumer(Consumer<Throwable> errorConsumer)

setupPayload

public RSocketFactory.ClientRSocketFactory setupPayload(Payload payload)

frameDecoder

public RSocketFactory.ClientRSocketFactory frameDecoder(PayloadDecoder payloadDecoder)