org.gradle.messaging.remote.internal

Interface AsyncConnection<T>

All Superinterfaces:

Dispatch<T>

All Known Implementing Classes:

AsyncConnectionAdapter

public interface AsyncConnection<T>
extends Dispatch<T>

A messaging endpoint which allows push-style dispatch and receive.

Implementations must be thread-safe.

Method Summary

Methods

Modifier and Type	Method and Description
void	dispatch(T message) Dispatches a message to this connection.
void	dispatchTo(Dispatch<? super T> handler) Adds a handler to receive incoming messages.

Method Detail

dispatch

void dispatch(T message)

Dispatches a message to this connection. The implementation should not block.

Specified by:

dispatch in interface Dispatch<T>

Parameters:

message - The message.

dispatchTo

void dispatchTo(Dispatch<? super T> handler)

Adds a handler to receive incoming messages. The handler does not need to be thread-safe. The handler should not block.

Parameters:

handler - The handler.