Modifier and Type | Method and Description |
---|---|
CompletableFuture<EventResult> |
EventManager.publish(Event event)
Publishes an event to the event queue.
|
Modifier and Type | Method and Description |
---|---|
EventResult |
WriteBytesEvent.get() |
EventResult |
CloseByteChannelEvent.get() |
EventResult |
ReadBytesEvent.get() |
Modifier and Type | Method and Description |
---|---|
EventResult |
CloseCharacterChannelEvent.get() |
EventResult |
ReadCharactersEvent.get() |
EventResult |
WriteCharactersEvent.get() |
Modifier and Type | Method and Description |
---|---|
EventResult |
CloseDelimitedRecordEvent.get() |
EventResult |
DelimitedRecordWriteEvent.get() |
EventResult |
DelimitedRecordReadEvent.get() |
EventResult |
HasNextDelimitedRecordEvent.get() |
EventResult |
DelimitedRecordReadAllEvent.get() |
Modifier and Type | Class and Description |
---|---|
class |
AlphaCollectionResult
Represent alphanumeric result collection.
|
class |
AlphaResult
Represents a series of characters.
|
class |
BooleanResult
Indicates a boolean result.
|
class |
ListResult
Represent List collection.
|
class |
NumericResult
Will represent the response obtained after reading/writing operations.
|
Modifier and Type | Method and Description |
---|---|
static void |
IOUtils.close(Channel byteChannel,
EventContext eventContext,
Function<EventResult,EventResult> function)
Closes the channel asynchronously.
|
static void |
IOUtils.close(Channel byteChannel,
EventContext eventContext,
Function<EventResult,EventResult> function)
Closes the channel asynchronously.
|
static void |
IOUtils.close(CharacterChannel charChannel,
EventContext eventContext,
Function<EventResult,EventResult> function)
Closes the character channel asynchronously.
|
static void |
IOUtils.close(CharacterChannel charChannel,
EventContext eventContext,
Function<EventResult,EventResult> function)
Closes the character channel asynchronously.
|
static void |
IOUtils.close(DelimitedRecordChannel charChannel,
EventContext eventContext,
Function<EventResult,EventResult> function)
Closes the delimited record channel asynchronously.
|
static void |
IOUtils.close(DelimitedRecordChannel charChannel,
EventContext eventContext,
Function<EventResult,EventResult> function)
Closes the delimited record channel asynchronously.
|
static void |
IOUtils.read(Channel channel,
byte[] content,
EventContext context,
Function<EventResult,EventResult> function)
Reads bytes asynchronously and trigger the callback.
|
static void |
IOUtils.read(Channel channel,
byte[] content,
EventContext context,
Function<EventResult,EventResult> function)
Reads bytes asynchronously and trigger the callback.
|
static void |
IOUtils.read(CharacterChannel characterChannel,
int numberOfCharacters,
EventContext context,
Function<EventResult,EventResult> function)
Reads characters from the channel.
|
static void |
IOUtils.read(CharacterChannel characterChannel,
int numberOfCharacters,
EventContext context,
Function<EventResult,EventResult> function)
Reads characters from the channel.
|
static void |
IOUtils.read(DelimitedRecordChannel recordChannel,
EventContext context,
Function<EventResult,EventResult> function)
Reads delimited records asynchronously.
|
static void |
IOUtils.read(DelimitedRecordChannel recordChannel,
EventContext context,
Function<EventResult,EventResult> function)
Reads delimited records asynchronously.
|
static void |
IOUtils.write(Channel channel,
byte[] content,
int offset,
EventContext context,
Function<EventResult,EventResult> function)
Writes bytes to a channel asynchronously.
|
static void |
IOUtils.write(Channel channel,
byte[] content,
int offset,
EventContext context,
Function<EventResult,EventResult> function)
Writes bytes to a channel asynchronously.
|
static void |
IOUtils.write(CharacterChannel characterChannel,
String content,
int offset,
EventContext context,
Function<EventResult,EventResult> function)
Writes characters to a channel.
|
static void |
IOUtils.write(CharacterChannel characterChannel,
String content,
int offset,
EventContext context,
Function<EventResult,EventResult> function)
Writes characters to a channel.
|
static void |
IOUtils.write(DelimitedRecordChannel recordChannel,
BStringArray records,
EventContext context,
Function<EventResult,EventResult> function)
Asynchronously writes delimited records to the channel.
|
static void |
IOUtils.write(DelimitedRecordChannel recordChannel,
BStringArray records,
EventContext context,
Function<EventResult,EventResult> function)
Asynchronously writes delimited records to the channel.
|
Copyright © 2018 WSO2. All rights reserved.