package lu.jpt.csparqltest.util;

import eu.larkc.csparql.cep.api.RdfQuadruple;
import lu.jpt.csparqltest.gui.TextObserverWindow;

public class WindowLoggingRdfStream extends LoggableRdfStream {

	private TextObserverWindow observerWindow;
	
	public WindowLoggingRdfStream(String iri) {
		super(iri);
		this.observerWindow = new TextObserverWindow("[RdfStream] "+iri);
	}
	
	/**
	 * This hook method gets called for every RdfQuadruple that is fed into the stream.
	 * @param quad that has been fed into the stream.
	 */
	@Override
	public void log(RdfQuadruple quad) {
		observerWindow.showQuadruple(quad);
	}

}