Skip to content

Commit

Permalink
next(iter()) replaced with list()[0] -- don't tease weak minds
Browse files Browse the repository at this point in the history
  • Loading branch information
popravich committed Jan 9, 2015
1 parent bcf8f0e commit c63c767
Show file tree
Hide file tree
Showing 10 changed files with 10 additions and 10 deletions.
2 changes: 1 addition & 1 deletion examples/core_dealer_router.py
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ def go():
zmq.ROUTER,
bind='tcp://127.0.0.1:*')

addr = next(iter(router.bindings()))
addr = list(router.bindings())[0]
queue = asyncio.Queue()
dealer, _ = yield from aiozmq.create_zmq_connection(
lambda: ZmqDealerProtocol(queue, dealer_closed),
Expand Down
2 changes: 1 addition & 1 deletion examples/rpc_custom_translator.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ def go():
server = yield from aiozmq.rpc.serve_rpc(
ServerHandler(), bind='tcp://*:*',
translation_table=translation_table)
server_addr = next(iter(server.transport.bindings()))
server_addr = list(server.transport.bindings())[0]

client = yield from aiozmq.rpc.connect_rpc(
connect=server_addr,
Expand Down
2 changes: 1 addition & 1 deletion examples/rpc_dict_handler.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ def b():
def go():
server = yield from aiozmq.rpc.serve_rpc(
handlers_dict, bind='tcp://*:*')
server_addr = next(iter(server.transport.bindings()))
server_addr = list(server.transport.bindings())[0]

client = yield from aiozmq.rpc.connect_rpc(
connect=server_addr)
Expand Down
2 changes: 1 addition & 1 deletion examples/rpc_dynamic.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ def func(self):
def go():
server = yield from aiozmq.rpc.serve_rpc(
DynamicHandler(), bind='tcp://*:*')
server_addr = next(iter(server.transport.bindings()))
server_addr = list(server.transport.bindings())[0]

client = yield from aiozmq.rpc.connect_rpc(
connect=server_addr)
Expand Down
2 changes: 1 addition & 1 deletion examples/rpc_exception_translator.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ def remote(self, val):
def go():
server = yield from aiozmq.rpc.serve_rpc(
ServerHandler(), bind='tcp://*:*')
server_addr = next(iter(server.transport.bindings()))
server_addr = list(server.transport.bindings())[0]

client = yield from aiozmq.rpc.connect_rpc(
connect=server_addr,
Expand Down
2 changes: 1 addition & 1 deletion examples/rpc_incorrect_calls.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ def remote_func(self, a: int, b: int) -> int:
def go():
server = yield from aiozmq.rpc.serve_rpc(
ServerHandler(), bind='tcp://*:*')
server_addr = next(iter(server.transport.bindings()))
server_addr = list(server.transport.bindings())[0]

client = yield from aiozmq.rpc.connect_rpc(
connect=server_addr)
Expand Down
2 changes: 1 addition & 1 deletion examples/rpc_pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ def go():
handler = Handler()
listener = yield from aiozmq.rpc.serve_pipeline(
handler, bind='tcp://*:*')
listener_addr = next(iter(listener.transport.bindings()))
listener_addr = list(listener.transport.bindings())[0]

notifier = yield from aiozmq.rpc.connect_pipeline(
connect=listener_addr)
Expand Down
2 changes: 1 addition & 1 deletion examples/rpc_pubsub.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ def go():
subscriber = yield from aiozmq.rpc.serve_pubsub(
handler, subscribe='topic', bind='tcp://127.0.0.1:*',
log_exceptions=True)
subscriber_addr = next(iter(subscriber.transport.bindings()))
subscriber_addr = list(subscriber.transport.bindings())[0]
print("SERVE", subscriber_addr)

publisher = yield from aiozmq.rpc.connect_pubsub(
Expand Down
2 changes: 1 addition & 1 deletion examples/rpc_simple.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ def remote_func(self, a: int, b: int) -> int:
def go():
server = yield from aiozmq.rpc.serve_rpc(
ServerHandler(), bind='tcp://*:*')
server_addr = next(iter(server.transport.bindings()))
server_addr = list(server.transport.bindings())[0]

client = yield from aiozmq.rpc.connect_rpc(
connect=server_addr)
Expand Down
2 changes: 1 addition & 1 deletion examples/rpc_with_subhandlers.py
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ def b(self):
def go():
server = yield from aiozmq.rpc.serve_rpc(
Handler('ident'), bind='tcp://*:*')
server_addr = next(iter(server.transport.bindings()))
server_addr = list(server.transport.bindings())[0]

client = yield from aiozmq.rpc.connect_rpc(
connect=server_addr)
Expand Down

0 comments on commit c63c767

Please sign in to comment.