RSocket.requestChannel throws if subscribed more than once #499

Closed

opened

on May 11, 2018

The reason is state from

rsocket-java/rsocket-core/src/main/java/io/rsocket/RSocketClient.java

Line 296 in 5fedb1d

final UnicastProcessor<Payload> receiver = UnicastProcessor.create();

have to be moved to

rsocket-java/rsocket-core/src/main/java/io/rsocket/RSocketClient.java

Line 312 in 5fedb1d

public Flux<Payload> get() {

Metadata

Assignees

No one assigned

Labels

No labels

No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests