import org.apache.solr.client.solrj.StreamingResponseCallback; //导入依赖的package包/类
@Test
public void testTagStreaming() throws IOException, SolrServerException {
  ModifiableSolrParams params = params();
  String input = "foo boston bar";//just one tag;
  QueryRequest req = new SolrTaggerRequest(params, input);
  req.setPath("/tag");

  final AtomicReference<SolrDocument> refDoc = new AtomicReference<>();
  req.setStreamingResponseCallback(new StreamingResponseCallback() {
    @Override
    public void streamSolrDocument(SolrDocument doc) {
      refDoc.set(doc);
    }

    @Override
    public void streamDocListInfo(long numFound, long start, Float maxScore) {

    }
  });
  QueryResponse rsp = req.process(solrServer);
  assertNotNull(rsp.getResponse().get("tags"));
  assertNotNull(refDoc.get());
  assertEquals("Boston", ((Field)refDoc.get().getFieldValue("name")).stringValue());
}
 

import org.apache.solr.client.solrj.StreamingResponseCallback; //导入依赖的package包/类
public StreamingBinaryResponseParser( StreamingResponseCallback cb )
{
  this.callback = cb;
}
 

import org.apache.solr.client.solrj.StreamingResponseCallback; //导入依赖的package包/类
@Override
public QueryResponse queryAndStreamResponse(SolrParams params, StreamingResponseCallback callback)
    throws SolrServerException, IOException {
  throw new RuntimeException("Not Implemented.");
}