WEBDIENSTE/langgraph
1
0
Fork 0
mirror of https://github.com/langchain-ai/langgraph.git synced 2026-09-13 21:27:52 +02:00
Code Issues Packages Projects Releases Wiki Activity

Update readme

Browse Source
This commit is contained in:
Nuno Campos
2023-10-05 11:11:10 +01:00
parent 4950c2405a
commit bd8260760d
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
README.md
+2 -2
View File
@@ -14,9 +14,9 @@ chain_one = Topic.IN.subscribe() | (lambda x: x + 'b') | topic_one.publish()
chain_two = topic_one.subscribe() | (lambda x: x + 'c') | Topic.OUT.publish()
conn = InMemoryPubSubConnection()
pubsub = PubSub(processes=(chain_one, chain_two), connection=conn)
pubsub = PubSub(chain_one, chain_two, connection=conn)
assert pubsub.invoke('a') == ['abc']
assert pubsub.invoke('a') == 'abc'
```
Check `tests` and `examples` for more examples.