Uses of Interface
org.n52.shetland.ogc.om.ObservationStream

Packages that use ObservationStream

Package	Description
org.n52.shetland.ogc.om
org.n52.shetland.ogc.sos.response

Uses of ObservationStream in org.n52.shetland.ogc.om

Classes in org.n52.shetland.ogc.om that implement ObservationStream

Modifier and Type	Class and Description
class	AbstractObservationStream
class	StreamingValue<S> Abstract streaming value class

Methods in org.n52.shetland.ogc.om that return ObservationStream

Modifier and Type	Method and Description
static ObservationStream	ObservationStream.empty() Creates an empty observation stream.
default ObservationStream	ObservationStream.filter(Predicate<OmObservation> predicate) Creates a new observation stream that filters the observatons from the original stream using the supplied predicate.
default ObservationStream	ObservationStream.flatMap(ThrowingFunction<OmObservation,ObservationStream,OwsExceptionReport> mapper) Creates a new observation stream from a mapping function that produces a stream for every observation in this stream.
default ObservationStream	ObservationStream.map(ThrowingUnaryOperator<OmObservation,OwsExceptionReport> operator) Produces a observation new stream from a mapping function that produces a new observation for every observation in this stream.
default ObservationStream	ObservationStream.merge() Creates a new stream out of this stream in which observations with the same observation constellation are merged.
default ObservationStream	ObservationStream.merge(ObservationMergeIndicator indicator) Creates a new stream out of this stream in which observations with the same observation constellation are merged.
default ObservationStream	ObservationStream.modify(ThrowingConsumer<OmObservation,OwsExceptionReport> consumer) Creates a new observation stream from an consumer that consumes every observation before it is emitted by the stream.
static ObservationStream	ObservationStream.of(Iterable<OmObservation> observations) Creates a new observation stream from the supplied iterable.
static ObservationStream	ObservationStream.of(Iterator<OmObservation> observations) Creates a new observation stream from the supplied iterator.
static ObservationStream	ObservationStream.of(OmObservation observation) Creates a new observation stream from the supplied observation.

Methods in org.n52.shetland.ogc.om that return types with arguments of type ObservationStream

Modifier and Type	Method and Description
Value<ObservationStream>	StreamingValue.getValue()

Method parameters in org.n52.shetland.ogc.om with type arguments of type ObservationStream

Modifier and Type	Method and Description
default ObservationStream	ObservationStream.flatMap(ThrowingFunction<OmObservation,ObservationStream,OwsExceptionReport> mapper) Creates a new observation stream from a mapping function that produces a stream for every observation in this stream.
void	StreamingValue.setValue(Value<ObservationStream> value)

Uses of ObservationStream in org.n52.shetland.ogc.sos.response

Classes in org.n52.shetland.ogc.sos.response that implement ObservationStream

Modifier and Type	Class and Description
class	AbstractStreaming

Methods in org.n52.shetland.ogc.sos.response that return ObservationStream

Modifier and Type	Method and Description
ObservationStream	AbstractObservationResponse.getObservationCollection()

Methods in org.n52.shetland.ogc.sos.response with parameters of type ObservationStream

Modifier and Type	Method and Description
AbstractObservationResponse	AbstractObservationResponse.setObservationCollection(ObservationStream observationCollection)