socket

type AbstractRSocket struct {
	FF func(Payload)
	MP func(Payload)
	RR func(Payload) Mono
	RS func(Payload) Flux
	RC func(Publisher) Flux
}

type ClientSocket interface {
	Closeable
	Responder
	Setup(ctx context.Context, setup *SetupInfo) (err error)
}

type Closeable interface {
	io.Closer
	OnClose(closer func())
}

type DuplexRSocket struct {
	// contains filtered or unexported fields
}

type Responder interface {
	// FireAndForget is a single one-way message.
	FireAndForget(msg Payload)
	// MetadataPush sends asynchronous Metadata frame.
	MetadataPush(msg Payload)
	// RequestResponse request single response.
	RequestResponse(msg Payload) Mono
	// RequestStream request a completable stream.
	RequestStream(msg Payload) Flux
	// RequestChannel request a completable stream in both directions.
	RequestChannel(msgs Publisher) Flux
}

type ServerSocket interface {
	Closeable
	Responder
	SetResponder(responder Responder)
	SetTransport(tp *transport.Transport)
	Pause() bool
	Start(ctx context.Context) error
	Token() (token []byte, ok bool)
}

type SetupInfo struct {
	Version           common.Version
	KeepaliveInterval time.Duration
	KeepaliveLifetime time.Duration
	Token             []byte
	DataMimeType      []byte
	Data              []byte
	MetadataMimeType  []byte
	Metadata          []byte
}