Uses of Class
com.cognite.client.stream.Publisher

Packages that use Publisher

Package	Description
com.cognite.client
com.cognite.client.stream

Uses of Publisher in com.cognite.client

Methods in com.cognite.client that return Publisher

Modifier and Type	Method	Description
Publisher<Asset>	Assets.stream()	Returns a Publisher that can stream Asset from Cognite Data Fusion.
Publisher<Event>	Events.stream()	Returns a Publisher that can stream Event from Cognite Data Fusion.

Uses of Publisher in com.cognite.client.stream

Methods in com.cognite.client.stream that return Publisher

Modifier and Type	Method	Description
static <T> Publisher<T>	Publisher.of(ListSource<T> listSource)
Publisher<T>	Publisher.withConsumer(Consumer<List<T>> consumer)	Add the consumer of the data stream.
Publisher<T>	Publisher.withEndTime(Instant endTime)	Sets the end time (i.e.
Publisher<T>	Publisher.withPollingInterval(Duration interval)	Sets the polling interval to check for updates to the source raw table.
Publisher<T>	Publisher.withPollingOffset(Duration interval)	Sets the polling offset.
Publisher<T>	Publisher.withRequest(Request request)	Sets a baseline Request to use when producing the steam of objects.
Publisher<T>	Publisher.withStartTime(Instant startTime)	Sets the start time (i.e.