lues.put(&quot;name&quot;, &quot;halo&quot;);</b>
<b class="fc">&nbsp;        v1.streamEdge(&quot;a&quot;, v2, keyValues);</b>
<b class="nc">&nbsp;        Assert.fail();</b>
&nbsp;    }
&nbsp;
&nbsp;
&nbsp;    @Test
&nbsp;    public void testStreamingVerticesAndEdges() throws InterruptedException {
<b class="fc">&nbsp;        this.sqlgGraph.tx().streamingBatchModeOn();</b>
<b class="fc">&nbsp;        LinkedHashMap&lt;String, Object&gt; keyValues = new LinkedHashMap&lt;&gt;();</b>
<b class="fc">&nbsp;       