adjust to new API

2013-10-23 19:05:10 +02:00
parent 83db700f0a
commit fe7a94adb2
1 changed files with 1 additions and 1 deletions
--- a/examples/websocket/streaming/streaming_producer_client.py
+++ b/examples/websocket/streaming/streaming_producer_client.py
@@ -47,7 +47,7 @@ class RandomByteStreamProducer:
      self.paused = False

      if not self.started:
-         self.proto.beginMessage(opcode = WebSocketProtocol.MESSAGE_TYPE_BINARY)
+         self.proto.beginMessage(binary = True)
         self.proto.beginMessageFrame(FRAME_SIZE)
         self.started = True