 null) {</b>
<b class="fc">&nbsp;            Thread.sleep(SLEEP_TIME);</b>
<b class="fc">&nbsp;            testEdgeFlushCloseStream_assert(this.sqlgGraph1);</b>
&nbsp;        }
&nbsp;    }
&nbsp;
&nbsp;    private void testEdgeFlushCloseStream_assert(SqlgGraph sqlgGraph) {
<b class="fc">&nbsp;        Assert.assertEquals(1, sqlgGraph.traversal().E().hasLabel(&quot;a&quot;).count().next(), 1);</b>
<b class="fc">&nbsp;        Assert.assertEquals(1, sqlgGraph.traversal().E().hasLabel(&quot;b&quot;).count().next