Uses of Interface
com.hazelcast.jet.core.Inbox

Packages that use Inbox

Package	Description
com.hazelcast.jet.core	Jet's Core API.
com.hazelcast.jet.core.test	Utilities for writing tests of Core API Processors.

Uses of Inbox in com.hazelcast.jet.core

Methods in com.hazelcast.jet.core with parameters of type Inbox

Modifier and Type	Method and Description
void	AbstractProcessor.process(int ordinal, Inbox inbox) Implements the boilerplate of dispatching against the ordinal, taking items from the inbox one by one, and invoking the processing logic on each.
default void	Processor.process(int ordinal, Inbox inbox) Called with a batch of items retrieved from an inbound edge's stream.
void	AbstractProcessor.restoreFromSnapshot(Inbox inbox) Implements the boilerplate of polling the inbox, casting the items to Map.Entry, and extracting the key and value.
default void	Processor.restoreFromSnapshot(Inbox inbox) Called when a batch of items is received during the "restore from snapshot" operation.

Uses of Inbox in com.hazelcast.jet.core.test

Classes in com.hazelcast.jet.core.test that implement Inbox

Modifier and Type	Class and Description
class	TestInbox Inbox implementation suitable to be used in tests.