client/src/main/java/eventstore/j/EsConnection.java
Source<IndexedEvent, NotUsed> allStreamsSource(
      Position fromPositionExclusive,
      boolean resolveLinkTos,
      UserCredentials credentials,
      boolean infinite);
/**
   * Creates a Source you can use to subscribes to all events. Existing events from position
   * onwards are read from the Event Store and presented to the user of
   * <code>Source</code> as if they had been pushed.
   * <p>
   * Once the end of the stream is read the <code>Source</code> transparently (to the user)
   * switches to push new events as they are written.
   * <p>
   * If events have already been received and resubscription from the same point
   * is desired, use the position representing the last event processed.
   *
   * @param fromPositionExclusive The position from which to start, or <code>null</code> to read all events
   * @param resolveLinkTos        Whether to resolve LinkTo events automatically
   * @param credentials           The optional user credentials to perform operation with
   * @param infinite              Whether to subscribe to the future events upon reading all current
   * @return A {@link akka.stream.javadsl.Source} representing all streams
   */
Creates a Source you can use to subscribes to all events. Existing events from position
onwards are read from the Event Store and presented to the user of
Source as if they had been pushed.

Once the end of the stream is read the Source transparently (to the user)
switches to push new events as they are written.

If events have already been received and resubscription from the same point
is desired, use the position representing the last event processed.


Creates a Source you can use to subscribes to all events . Existing events from position onwards are read from the Event Store and presented to the user of Source as if they had been pushed . Once the end of the stream is read the Source transparently ( to the user ) switches to push new events as they are written . If events have already been received and resubscription from the same point is desired use the position representing the last event processed .
Source<IndexedEvent, NotUsed> allStreamsSource(
      Position fromPositionExclusive,
      boolean resolveLinkTos,
      UserCredentials credentials,
      boolean infinite);
Source < IndexedEvent , NotUsed > allStreamsSource ( Position fromPositionExclusive , boolean resolveLinkTos , UserCredentials credentials , boolean infinite ) ;
Creates a Source you can use to subscribes to all events.
Creates a Source you can use to subscribes to all events .