Skip to content

Commit 96cf224

Browse files
committed
Add optionally loop param in acouchbase.Bucket
1 parent 25eccd7 commit 96cf224

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

acouchbase/bucket.py

+3-2
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,9 @@
1010

1111

1212
class Bucket(AsyncBucket):
13-
def __init__(self, *args, **kwargs):
14-
loop = asyncio.get_event_loop()
13+
def __init__(self, *args, loop=None, **kwargs):
14+
loop = loop or asyncio.get_event_loop()
15+
1516
super(Bucket, self).__init__(IOPS(loop), *args, **kwargs)
1617
self._loop = loop
1718

0 commit comments

Comments
 (0)