{"action":"created","issue":{"url":"https://api.github.com/repos/sensorbee/sensorbee/issues/101","repository_url":"https://api.github.com/repos/sensorbee/sensorbee","labels_url":"https://api.github.com/repos/sensorbee/sensorbee/issues/101/labels{/name}","comments_url":"https://api.github.com/repos/sensorbee/sensorbee/issues/101/comments","events_url":"https://api.github.com/repos/sensorbee/sensorbee/issues/101/events","html_url":"https://github.com/sensorbee/sensorbee/issues/101","id":163010971,"number":101,"title":"Sink.StopOnDisconnect is blocked forever in TopologyBuilder.AddSelectUnionStmt","user":{"login":"nobu-k","id":61242,"avatar_url":"https://avatars.githubusercontent.com/u/61242?v=3","gravatar_id":"","url":"https://api.github.com/users/nobu-k","html_url":"https://github.com/nobu-k","followers_url":"https://api.github.com/users/nobu-k/followers","following_url":"https://api.github.com/users/nobu-k/following{/other_user}","gists_url":"https://api.github.com/users/nobu-k/gists{/gist_id}","starred_url":"https://api.github.com/users/nobu-k/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/nobu-k/subscriptions","organizations_url":"https://api.github.com/users/nobu-k/orgs","repos_url":"https://api.github.com/users/nobu-k/repos","events_url":"https://api.github.com/users/nobu-k/events{/privacy}","received_events_url":"https://api.github.com/users/nobu-k/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2016-06-29T19:48:50Z","updated_at":"2016-07-07T16:53:02Z","closed_at":null,"body":"I encountered an issue in `bql.TopologyBuilder.AddSelectUnionStmt`:\r\n\r\n1. Connect Sink to (i.e. SELECTing from) a Source that generates tuples very quickly\r\n2. The pipe between the Source and the Sink becomes full\r\n3. Call `StopOnDisconnect` of `Sink` but it's blocked until the `Sink` actually start consuming tuples\r\n4. Because a chan is not returned from `bql.TopologyBuilder.AddSelectUnionStmt`, nobody can consume a tuple from the pipe and the method is blocked forever"},"comment":{"url":"https://api.github.com/repos/sensorbee/sensorbee/issues/comments/231139522","html_url":"https://github.com/sensorbee/sensorbee/issues/101#issuecomment-231139522","issue_url":"https://api.github.com/repos/sensorbee/sensorbee/issues/101","id":231139522,"user":{"login":"disktnk","id":414255,"avatar_url":"https://avatars.githubusercontent.com/u/414255?v=3","gravatar_id":"","url":"https://api.github.com/users/disktnk","html_url":"https://github.com/disktnk","followers_url":"https://api.github.com/users/disktnk/followers","following_url":"https://api.github.com/users/disktnk/following{/other_user}","gists_url":"https://api.github.com/users/disktnk/gists{/gist_id}","starred_url":"https://api.github.com/users/disktnk/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/disktnk/subscriptions","organizations_url":"https://api.github.com/users/disktnk/orgs","repos_url":"https://api.github.com/users/disktnk/repos","events_url":"https://api.github.com/users/disktnk/events{/privacy}","received_events_url":"https://api.github.com/users/disktnk/received_events","type":"User","site_admin":false},"created_at":"2016-07-07T16:53:02Z","updated_at":"2016-07-07T16:53:02Z","body":"thanks for analysis!"}}
{"actor":{"display_login":"disktnk"}}