Update Readme.md (#47)

* Update Readme.md * Update README.md * Update README.md
googleapis · May 19, 2020 · 2b05194 · 2b05194
1 parent f7750cb
commit 2b05194
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pubsublite-beam-io/README.md b/pubsublite-beam-io/README.md
@@ -44,9 +44,9 @@ soon.
 
     ...
 
-    PCollection<Message> messages = ...;
-    messages.apply("Write messages", PubsubLiteIO.write(
-        PublisherOptions.newBuilder()
+    Pipeline pipeline = ...;
+    PCollection<SequencedMessage> messages = pipeline.apply("Read messages", PubsubLiteIO.read(
+        SubscriberOptions.newBuilder()
             .setSubscriptionPath(SubscriptionPaths.newBuilder()
                 .setZone(CloudZone.parse(ZONE))
                 .setProject(ProjectNumber.of(PROJECT_NUM))