fix pep8
This commit is contained in:
parent
30ddfbda98
commit
f63ee614ca
@ -1,8 +1,14 @@
|
||||
pyflakes:
|
||||
pyflakes .
|
||||
|
||||
# run PEP8 check and print statistics
|
||||
pep8:
|
||||
pep8 --statistics --ignore=E501 -qq .
|
||||
|
||||
# run PEP8 check and show source for offending code
|
||||
pep8show:
|
||||
pep8 --show-source --ignore=E501 .
|
||||
|
||||
# pep8 --select=E231 --show-source
|
||||
|
||||
autopep8:
|
||||
|
@ -23,11 +23,12 @@ import subprocess
|
||||
|
||||
prompt = 'user@machine:~/autobahn-python$ '
|
||||
|
||||
|
||||
def interkey_interval():
|
||||
"""in milliseconds"""
|
||||
# return 0 # makes testing faster
|
||||
return (random.lognormvariate(0.0, 0.5) * 30.0) / 1000.0
|
||||
return float(random.randrange(10,50)) / 1000.0
|
||||
return float(random.randrange(10, 50)) / 1000.0
|
||||
|
||||
|
||||
def type_it_out(line):
|
||||
|
@ -2,6 +2,7 @@ from os import environ
|
||||
import asyncio
|
||||
from autobahn.asyncio.wamp import ApplicationSession, ApplicationRunner
|
||||
|
||||
|
||||
class MyComponent(ApplicationSession):
|
||||
@asyncio.coroutine
|
||||
def onJoin(self, details):
|
||||
|
@ -2,6 +2,7 @@ from os import environ
|
||||
import asyncio
|
||||
from autobahn.asyncio.wamp import ApplicationSession, ApplicationRunner
|
||||
|
||||
|
||||
class MyComponent(ApplicationSession):
|
||||
@asyncio.coroutine
|
||||
def onJoin(self, details):
|
||||
|
@ -50,10 +50,9 @@ class Component(ApplicationSession):
|
||||
|
||||
counter = 0
|
||||
while True:
|
||||
publication = yield from self.publish(
|
||||
'com.myapp.topic1', counter,
|
||||
options=PublishOptions(acknowledge=True, disclose_me=True, exclude_me=False)
|
||||
)
|
||||
publication = yield from self.publish(u'com.myapp.topic1',
|
||||
counter,
|
||||
options=PublishOptions(acknowledge=True, disclose_me=True, exclude_me=False))
|
||||
print("Event published with publication ID {}".format(publication.id))
|
||||
counter += 1
|
||||
yield from asyncio.sleep(1)
|
||||
|
@ -27,6 +27,7 @@ from twisted.internet.defer import inlineCallbacks, Deferred, returnValue
|
||||
from twisted.internet.error import ProcessExitedAlready
|
||||
from twisted.python.failure import Failure
|
||||
from twisted.internet import reactor
|
||||
from twisted.internet.task import react
|
||||
|
||||
from autobahn.twisted.util import sleep
|
||||
|
||||
@ -68,7 +69,7 @@ class CrossbarProcessProtocol(ProcessProtocol):
|
||||
while '\n' in self._err:
|
||||
idx = self._err.find('\n')
|
||||
line = self._err[:idx]
|
||||
self._err = self._err[idx+1:]
|
||||
self._err = self._err[idx + 1:]
|
||||
sys.stderr.write(self.prefix + self.color + line + Fore.RESET + '\n')
|
||||
|
||||
def processEnded(self, reason):
|
||||
@ -233,6 +234,5 @@ def main(reactor):
|
||||
returnValue(5)
|
||||
|
||||
|
||||
from twisted.internet.task import react
|
||||
if __name__ == '__main__':
|
||||
sys.exit(react(main))
|
||||
|
@ -33,6 +33,7 @@ from twisted.internet.defer import inlineCallbacks
|
||||
from autobahn import wamp
|
||||
from autobahn.twisted.wamp import ApplicationSession, ApplicationRunner
|
||||
|
||||
|
||||
class Calculator(ApplicationSession):
|
||||
|
||||
@inlineCallbacks
|
||||
|
@ -4,6 +4,7 @@ from twisted.internet.task import LoopingCall
|
||||
from autobahn.twisted.wamp import ApplicationSession, ApplicationRunner
|
||||
# or: from autobahn.asyncio.wamp import ApplicationSession
|
||||
|
||||
|
||||
class MyComponent(ApplicationSession):
|
||||
@inlineCallbacks
|
||||
def onJoin(self, details):
|
||||
|
@ -3,6 +3,7 @@ from twisted.internet.defer import inlineCallbacks
|
||||
from autobahn.twisted.wamp import ApplicationSession, ApplicationRunner
|
||||
# or: from autobahn.asyncio.wamp import ApplicationSession
|
||||
|
||||
|
||||
class MyComponent(ApplicationSession):
|
||||
@inlineCallbacks
|
||||
def onJoin(self, details):
|
||||
|
Loading…
Reference in New Issue
Block a user