From 6104f89925e87e8ca6853f60b02756c7af6ee9a6 Mon Sep 17 00:00:00 2001 From: AlexejStukov Date: Thu, 21 Jul 2016 08:53:24 +0200 Subject: [PATCH] added encoding and self.stream-check to trigger_outbound --- channels/binding/base.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/channels/binding/base.py b/channels/binding/base.py index 9abbce6..672b5a3 100644 --- a/channels/binding/base.py +++ b/channels/binding/base.py @@ -97,9 +97,13 @@ class Binding(object): self = cls() self.instance = instance # Check to see if we're covered - for group_name in self.group_names(instance, action): - group = Group(group_name) - group.send(self.serialize(instance, action)) + assert self.stream is not None + payload = self.serialize(instance, action) + if payload != {}: + message = WebsocketDemultiplexer.encode(self.stream, payload) + for group_name in self.group_names(instance, action): + group = Group(group_name) + group.send(message) def group_names(self, instance, action): """