I have corroborated this by opening the Crossbar.io router in debug mode, and it shows logs corresponding to the published messages after the time is over (not during the run as expected).
My script is long, complex and includes a combined frontend and backend for Crossbar/Twisted/Autobahn. I feel I would risk misreporting if I tried to condense and include it.
What possible reason is there for publish to not happen instantaneously?
--
You received this message because you are subscribed to the Google Groups "Autobahn" group.
To unsubscribe from this group and stop receiving emails from it, send an email to autobahnws+...@googlegroups.com.
To post to this group, send email to autob...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/autobahnws/5c04c639-d1d7-45ca-81cd-994dc9abe84e%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
@component.on_join@inlineCallbacksdef join(session, details): print("joined {}: {}".format(session, details))
def publish(value): session.publish(u'com.asdf.ghjk', {"value": value}) pass
def my_script(thing): publish('TEST 1')
sleep(2) publish('TEST 2')
try: yield session.register(my_script, u'com.asdf.ghjk') except Exception as e: print("could not register procedure: {0}".format(e))
To view this discussion on the web visit https://groups.google.com/d/msgid/autobahnws/f1452e40-edc2-43cc-8e58-a2a5872984c2%40googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/autobahnws/d575e5dd-62e4-4622-9699-4e5f95911a55%40googlegroups.com.