Package | Description |
---|---|
org.zeromq.api | |
org.zeromq.jzmq | |
org.zeromq.jzmq.poll | |
org.zeromq.jzmq.reactor |
Modifier and Type | Method and Description |
---|---|
Pollable |
Context.newPollable(SelectableChannel channel,
PollerType... options)
Create a new Pollable from the socket, with the requested options.
|
Pollable |
Context.newPollable(Socket socket,
PollerType... options)
Create a new Pollable from the socket, with the requested options.
|
Modifier and Type | Method and Description |
---|---|
void |
Reactor.addPollable(Pollable pollable,
LoopHandler handler)
Add a new Pollable to this Reactor.
|
void |
LoopHandler.execute(Reactor reactor,
Pollable pollable)
Execute a loop operation.
|
void |
LoopAdapter.execute(Reactor reactor,
Pollable pollable) |
void |
PollListener.handleError(Pollable pollable)
Callback to handle errors.
|
void |
PollAdapter.handleError(Pollable pollable) |
void |
PollListener.handleIn(Pollable pollable)
Callback to handle incoming messages.
|
void |
PollAdapter.handleIn(Pollable pollable) |
void |
PollListener.handleOut(Pollable pollable)
Callback to handle outgoing messages.
|
void |
PollAdapter.handleOut(Pollable pollable) |
int |
Poller.register(Pollable pollable,
PollListener listener)
Register a new poll item.
|
Modifier and Type | Method and Description |
---|---|
Pollable |
ManagedContext.newPollable(SelectableChannel channel,
PollerType... options) |
Pollable |
ManagedContext.newPollable(Socket socket,
PollerType... options) |
Modifier and Type | Class and Description |
---|---|
class |
PollableImpl |
Modifier and Type | Method and Description |
---|---|
int |
PollerImpl.register(Pollable pollable,
PollListener listener) |
PollerBuilder |
PollerBuilder.withPollable(Pollable pollable,
PollListener listener) |
Constructor and Description |
---|
PollerImpl(ManagedContext context,
Map<Pollable,PollListener> pollableMap) |
Modifier and Type | Method and Description |
---|---|
void |
ReactorImpl.addPollable(Pollable pollable,
LoopHandler handler) |
ReactorBuilder |
ReactorBuilder.withPollable(Pollable pollable,
LoopHandler handler) |
Copyright © 2019. All rights reserved.