diff --git a/nextgraph/src/local_broker.rs b/nextgraph/src/local_broker.rs index 54a41fc..6624b33 100644 --- a/nextgraph/src/local_broker.rs +++ b/nextgraph/src/local_broker.rs @@ -18,6 +18,7 @@ use async_std::sync::{Arc, Condvar, Mutex, RwLock}; use futures::channel::mpsc; use futures::{SinkExt, StreamExt}; use lazy_static::lazy_static; +use ng_net::orm::OrmShapeType; use ng_oxigraph::oxrdf::Triple; use once_cell::sync::Lazy; use pdf_writer::{Content, Finish, Name, Pdf, Rect, Ref, Str}; @@ -2754,6 +2755,16 @@ async fn get_broker() -> Result Result<(Receiver, CancelFn), NgError> { + let mut request = AppRequest::new_orm_start(scope, shape_type); + request.set_session_id(session_id); + app_request_stream(request).await +} + pub async fn doc_sparql_construct( session_id: u64, sparql: String,