Skip to content

Add Listener, Web server close on header, use Pipe instead of Manager in eventing core #720

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 14 commits into from
Nov 10, 2021
Merged

Add Listener, Web server close on header, use Pipe instead of Manager in eventing core #720

Changes from 1 commit
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
8e5f858
Abstract out a Listener class
abhinavsingh Nov 10, 2021
dd99722
unused
abhinavsingh Nov 10, 2021
2fe67f0
Use connection instead of manager queue
abhinavsingh Nov 10, 2021
383a0f3
For web close connection of client requested via headers
abhinavsingh Nov 10, 2021
2d74000
Remove eventing WIP module
abhinavsingh Nov 10, 2021
30c869f
Sub and Unsub ack
abhinavsingh Nov 10, 2021
9587e69
Fix tests
abhinavsingh Nov 10, 2021
a387f90
mypy and flake8
abhinavsingh Nov 10, 2021
8a0668f
comma
abhinavsingh Nov 10, 2021
9aae0db
Move callback within EventSubscriber constructor
abhinavsingh Nov 10, 2021
af47dc0
[pre-commit.ci] auto fixes from pre-commit.com hooks
pre-commit-ci[bot] Nov 10, 2021
63f8fd5
Skip test_unix_path_listener on Windows
abhinavsingh Nov 10, 2021
60cbdd0
Merge branch 'event-conn' of github.com:abhinavsingh/proxy.py into ev…
abhinavsingh Nov 10, 2021
858c9ea
Spelling fix
abhinavsingh Nov 10, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
[pre-commit.ci] auto fixes from pre-commit.com hooks 
for more information, see https://pre-commit.ci
  • Loading branch information
@pre-commit-ci
pre-commit-ci[bot] committed Nov 10, 2021
commit af47dc006ad735d7d99435a3701ab39238ab613b
9 changes: 6 additions & 3 deletions proxy/core/event/subscriber.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -125,18 +125,21 @@ def relay(
if ev['event_name'] == eventNames.SUBSCRIBED:
logger.info(
'Subscriber#{0} subscribe ack received'.format(
sub_id),
sub_id,
),
)
elif ev['event_name'] == eventNames.UNSUBSCRIBED:
logger.info(
'Subscriber#{0} unsubscribe ack received'.format(
sub_id),
sub_id,
),
)
break
elif ev['event_name'] == eventNames.DISPATCHER_SHUTDOWN:
logger.info(
'Subscriber#{0} received dispatcher shutdown event'.format(
sub_id),
sub_id,
),
)
break
else:
Expand Down