[FROZEN][Bridge] Followed a stream from a Worker through a standalone operation.

temporalio/contrib/streams/nexus/__init__.py

@@ -52,9 +52,26 @@
 :class:`ClientTransport` calls ``ExecuteSyncNexusOperation`` with the
 caller's own client, and :class:`HttpTransport` the HTTP ingress of a
 self-hosted server.
+
+A Worker follows such a stream with no Workflow. :func:`follow_stream` starts
+the operation as a standalone operation with a callback to the Worker, and
+:class:`StreamFollowerService` on that Worker hands each new batch to a
+:class:`StreamFollower`, then the close. It reads through
+:class:`StoreTransport` on its client's store, or through
+:class:`ClientTransport` or :class:`TemporalStreamsHttpClient` for a stream
+in another namespace or store.
 """
 
 from temporalio.contrib.streams import StreamRef
+from temporalio.contrib.streams.nexus._follower import (
+    FollowerBatch,
+    FollowOutcome,
+    StoreTransport,
+    StreamFollower,
+    StreamFollowerService,
+    StreamReadTransport,
+    follow_stream,
+)
 from temporalio.contrib.streams.nexus._generated import (
     AppendInput,
     AppendOutput,
@@ -87,21 +104,28 @@
 __all__ = [
     "AppendInput",
     "AppendOutput",
+    "FollowerBatch",
+    "FollowOutcome",
     "HTTPStatusError",
     "ReadInput",
     "ReadOutput",
     "ReadStaleRecord",
     "ReadPosition",
     "ReadSupersession",
     "RecordWire",
+    "StoreTransport",
     "StreamAccess",
     "StreamCursor",
+    "StreamFollower",
+    "StreamFollowerService",
     "StreamIncompleteError",
     "StreamOperationHandler",
+    "StreamReadTransport",
     "StreamReader",
     "StreamRef",
     "TemporalStreams",
     "TemporalStreamsHandler",
     "TemporalStreamsHttpClient",
+    "follow_stream",
     "stream_ref_from_token",
 ]