diff --git a/docs/examples/consumer.py b/docs/examples/consumer.py index bb1a58e75..a0d1a6a43 100644 --- a/docs/examples/consumer.py +++ b/docs/examples/consumer.py @@ -3,11 +3,13 @@ schema = Schema("hello_world") + @schema.define class Message: timestamp = float message = str + db = connect('localhost', 8000, 'TOKEN') db.subscribeToSchema(schema) diff --git a/docs/examples/producer.py b/docs/examples/producer.py index a81dc0221..6f0c45ae4 100644 --- a/docs/examples/producer.py +++ b/docs/examples/producer.py @@ -3,11 +3,13 @@ schema = Schema("hello_world") + @schema.define class Message: timestamp = float message = str + db = connect('localhost', 8000, 'TOKEN') db.subscribeToSchema(schema)