============================================================= FAILURES =============================================================
___________________________ TestConcurrentStreamOpenPerformance.test_concurrent_stream_open_performance ____________________________
self = <test_concurrent_stream_open.TestConcurrentStreamOpenPerformance object at 0x107d86a50>
frame_factory = <helpers.FrameFactory object at 0x107d86cd0>
 def test_concurrent_stream_open_performance(self, frame_factory):
 """
 Opening many concurrent streams is constant time operation
 """
 num_concurrent_streams = 10000
 c = h2.connection.H2Connection()
 c.initiate_connection()
 start = time.time()
 for i in xrange(num_concurrent_streams):
 c.send_headers(1 + (2 * i), self.example_request_headers, end_stream=False)
 c.clear_outbound_data_buffer()
 end = time.time()
 
 run_time = end - start
> assert run_time < 3
E assert 36.598387002944946 < 3
test/test_concurrent_stream_open.py:51: AssertionError
==================================================== 1 failed in 36.66 seconds =====================================================

============================================================================================================ test session starts =============================================================================================================
platform darwin -- Python 2.7.15, pytest-3.4.2, py-1.7.0, pluggy-0.6.0
hypothesis profile 'default' -> database=DirectoryBasedExampleDatabase('/Users/andrew/workspace/hyper-h2/.hypothesis/examples')
rootdir: /Users/andrew/workspace/hyper-h2, inifile:
plugins: xdist-1.22.2, profiling-1.6.0, forked-1.0.2, cov-2.5.1, hypothesis-4.5.11
collected 1 item 
test/test_concurrent_stream_open.py . [100%]
========================================================================================================== 1 passed in 1.06 seconds ==========================================================================================================

def sync_state_change(func):
 def wrapper(self, *args, **kwargs):
 # Collect state at the beginning.
 start_state = self.state_machine.state
 started_open = self.open
 started_closed = not started_open
 # Do the state change (if any).
 result = func(self, *args, **kwargs)
 # Collect state at the end.
 end_state = self.state_machine.state
 ended_open = self.open
 ended_closed = not ended_open
 # If at any point we've tranwsitioned to the CLOSED state
 # from any other state, close our stream.
 if end_state == StreamState.CLOSED and start_state != end_state:
 if self._close_stream_callback:
 self._close_stream_callback(self.stream_id)
 # Clear callback so we only call this once per stream
 self._close_stream_callback = None
 # If we were open, but are now closed, decrement
 # the open stream count, and call the close callback.
 if started_open and ended_closed:
 if self._decrement_open_stream_count_callback:
 self._decrement_open_stream_count_callback(self.stream_id,
 -1,)
 # Clear callback so we only call this once per stream
 self._decrement_open_stream_count_callback = None
 # If we were closed, but are now open, increment
 # the open stream count.
 elif started_closed and ended_open:
> if self._increment_open_stream_count_callback:
> self._increment_open_stream_count_callback(self.stream_id,
> 1,)
> # Clear callback so we only call this once per stream
> self._increment_open_stream_count_callback = None
 return result
 return wrapper