683 lines
26 KiB
JavaScript
683 lines
26 KiB
JavaScript
goog.provide('cljs.core.async.impl.channels');
|
|
|
|
/**
|
|
* @constructor
|
|
* @implements {cljs.core.IMeta}
|
|
* @implements {cljs.core.IDeref}
|
|
* @implements {cljs.core.IWithMeta}
|
|
*/
|
|
cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475 = (function (val,meta12476){
|
|
this.val = val;
|
|
this.meta12476 = meta12476;
|
|
this.cljs$lang$protocol_mask$partition0$ = 425984;
|
|
this.cljs$lang$protocol_mask$partition1$ = 0;
|
|
});
|
|
(cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475.prototype.cljs$core$IWithMeta$_with_meta$arity$2 = (function (_12477,meta12476__$1){
|
|
var self__ = this;
|
|
var _12477__$1 = this;
|
|
return (new cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475(self__.val,meta12476__$1));
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475.prototype.cljs$core$IMeta$_meta$arity$1 = (function (_12477){
|
|
var self__ = this;
|
|
var _12477__$1 = this;
|
|
return self__.meta12476;
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475.prototype.cljs$core$IDeref$_deref$arity$1 = (function (_){
|
|
var self__ = this;
|
|
var ___$1 = this;
|
|
return self__.val;
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475.getBasis = (function (){
|
|
return new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Symbol(null,"val","val",1769233139,null),new cljs.core.Symbol(null,"meta12476","meta12476",1202178637,null)], null);
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475.cljs$lang$type = true);
|
|
|
|
(cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475.cljs$lang$ctorStr = "cljs.core.async.impl.channels/t_cljs$core$async$impl$channels12475");
|
|
|
|
(cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475.cljs$lang$ctorPrWriter = (function (this__5330__auto__,writer__5331__auto__,opt__5332__auto__){
|
|
return cljs.core._write(writer__5331__auto__,"cljs.core.async.impl.channels/t_cljs$core$async$impl$channels12475");
|
|
}));
|
|
|
|
/**
|
|
* Positional factory function for cljs.core.async.impl.channels/t_cljs$core$async$impl$channels12475.
|
|
*/
|
|
cljs.core.async.impl.channels.__GT_t_cljs$core$async$impl$channels12475 = (function cljs$core$async$impl$channels$__GT_t_cljs$core$async$impl$channels12475(val,meta12476){
|
|
return (new cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475(val,meta12476));
|
|
});
|
|
|
|
|
|
cljs.core.async.impl.channels.box = (function cljs$core$async$impl$channels$box(val){
|
|
return (new cljs.core.async.impl.channels.t_cljs$core$async$impl$channels12475(val,cljs.core.PersistentArrayMap.EMPTY));
|
|
});
|
|
|
|
/**
|
|
* @constructor
|
|
*/
|
|
cljs.core.async.impl.channels.PutBox = (function (handler,val){
|
|
this.handler = handler;
|
|
this.val = val;
|
|
});
|
|
|
|
(cljs.core.async.impl.channels.PutBox.getBasis = (function (){
|
|
return new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Symbol(null,"handler","handler",1444934915,null),new cljs.core.Symbol(null,"val","val",1769233139,null)], null);
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.PutBox.cljs$lang$type = true);
|
|
|
|
(cljs.core.async.impl.channels.PutBox.cljs$lang$ctorStr = "cljs.core.async.impl.channels/PutBox");
|
|
|
|
(cljs.core.async.impl.channels.PutBox.cljs$lang$ctorPrWriter = (function (this__5330__auto__,writer__5331__auto__,opt__5332__auto__){
|
|
return cljs.core._write(writer__5331__auto__,"cljs.core.async.impl.channels/PutBox");
|
|
}));
|
|
|
|
/**
|
|
* Positional factory function for cljs.core.async.impl.channels/PutBox.
|
|
*/
|
|
cljs.core.async.impl.channels.__GT_PutBox = (function cljs$core$async$impl$channels$__GT_PutBox(handler,val){
|
|
return (new cljs.core.async.impl.channels.PutBox(handler,val));
|
|
});
|
|
|
|
cljs.core.async.impl.channels.put_active_QMARK_ = (function cljs$core$async$impl$channels$put_active_QMARK_(box){
|
|
return cljs.core.async.impl.protocols.active_QMARK_(box.handler);
|
|
});
|
|
cljs.core.async.impl.channels.MAX_DIRTY = (64);
|
|
|
|
/**
|
|
* @interface
|
|
*/
|
|
cljs.core.async.impl.channels.MMC = function(){};
|
|
|
|
var cljs$core$async$impl$channels$MMC$abort$dyn_12538 = (function (this$){
|
|
var x__5393__auto__ = (((this$ == null))?null:this$);
|
|
var m__5394__auto__ = (cljs.core.async.impl.channels.abort[goog.typeOf(x__5393__auto__)]);
|
|
if((!((m__5394__auto__ == null)))){
|
|
return (m__5394__auto__.cljs$core$IFn$_invoke$arity$1 ? m__5394__auto__.cljs$core$IFn$_invoke$arity$1(this$) : m__5394__auto__.call(null,this$));
|
|
} else {
|
|
var m__5392__auto__ = (cljs.core.async.impl.channels.abort["_"]);
|
|
if((!((m__5392__auto__ == null)))){
|
|
return (m__5392__auto__.cljs$core$IFn$_invoke$arity$1 ? m__5392__auto__.cljs$core$IFn$_invoke$arity$1(this$) : m__5392__auto__.call(null,this$));
|
|
} else {
|
|
throw cljs.core.missing_protocol("MMC.abort",this$);
|
|
}
|
|
}
|
|
});
|
|
cljs.core.async.impl.channels.abort = (function cljs$core$async$impl$channels$abort(this$){
|
|
if((((!((this$ == null)))) && ((!((this$.cljs$core$async$impl$channels$MMC$abort$arity$1 == null)))))){
|
|
return this$.cljs$core$async$impl$channels$MMC$abort$arity$1(this$);
|
|
} else {
|
|
return cljs$core$async$impl$channels$MMC$abort$dyn_12538(this$);
|
|
}
|
|
});
|
|
|
|
|
|
/**
|
|
* @constructor
|
|
* @implements {cljs.core.async.impl.channels.MMC}
|
|
* @implements {cljs.core.async.impl.protocols.Channel}
|
|
* @implements {cljs.core.async.impl.protocols.WritePort}
|
|
* @implements {cljs.core.async.impl.protocols.ReadPort}
|
|
*/
|
|
cljs.core.async.impl.channels.ManyToManyChannel = (function (takes,dirty_takes,puts,dirty_puts,buf,closed,add_BANG_){
|
|
this.takes = takes;
|
|
this.dirty_takes = dirty_takes;
|
|
this.puts = puts;
|
|
this.dirty_puts = dirty_puts;
|
|
this.buf = buf;
|
|
this.closed = closed;
|
|
this.add_BANG_ = add_BANG_;
|
|
});
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.prototype.cljs$core$async$impl$channels$MMC$ = cljs.core.PROTOCOL_SENTINEL);
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.prototype.cljs$core$async$impl$channels$MMC$abort$arity$1 = (function (this$){
|
|
var self__ = this;
|
|
var this$__$1 = this;
|
|
while(true){
|
|
var putter_12539 = self__.puts.pop();
|
|
if((putter_12539 == null)){
|
|
} else {
|
|
var put_handler_12540 = putter_12539.handler;
|
|
var val_12541 = putter_12539.val;
|
|
if(put_handler_12540.cljs$core$async$impl$protocols$Handler$active_QMARK_$arity$1(null)){
|
|
var put_cb_12542 = put_handler_12540.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
cljs.core.async.impl.dispatch.run(((function (put_cb_12542,put_handler_12540,val_12541,putter_12539,this$__$1){
|
|
return (function (){
|
|
return (put_cb_12542.cljs$core$IFn$_invoke$arity$1 ? put_cb_12542.cljs$core$IFn$_invoke$arity$1(true) : put_cb_12542.call(null,true));
|
|
});})(put_cb_12542,put_handler_12540,val_12541,putter_12539,this$__$1))
|
|
);
|
|
} else {
|
|
continue;
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
|
|
self__.puts.cleanup(cljs.core.constantly(false));
|
|
|
|
return this$__$1.cljs$core$async$impl$protocols$Channel$close_BANG_$arity$1(null);
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.prototype.cljs$core$async$impl$protocols$WritePort$ = cljs.core.PROTOCOL_SENTINEL);
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.prototype.cljs$core$async$impl$protocols$WritePort$put_BANG_$arity$3 = (function (this$,val,handler){
|
|
var self__ = this;
|
|
var this$__$1 = this;
|
|
if((!((val == null)))){
|
|
} else {
|
|
throw (new Error(["Assert failed: ","Can't put nil on a channel","\n","(not (nil? val))"].join('')));
|
|
}
|
|
|
|
var closed__$1 = self__.closed;
|
|
if((!(handler.cljs$core$async$impl$protocols$Handler$active_QMARK_$arity$1(null)))){
|
|
return cljs.core.async.impl.channels.box((!(closed__$1)));
|
|
} else {
|
|
if(closed__$1){
|
|
handler.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
|
|
return cljs.core.async.impl.channels.box(false);
|
|
} else {
|
|
if(cljs.core.truth_((function (){var and__5043__auto__ = self__.buf;
|
|
if(cljs.core.truth_(and__5043__auto__)){
|
|
return cljs.core.not(self__.buf.cljs$core$async$impl$protocols$Buffer$full_QMARK_$arity$1(null));
|
|
} else {
|
|
return and__5043__auto__;
|
|
}
|
|
})())){
|
|
handler.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
|
|
var done_QMARK_ = cljs.core.reduced_QMARK_((self__.add_BANG_.cljs$core$IFn$_invoke$arity$2 ? self__.add_BANG_.cljs$core$IFn$_invoke$arity$2(self__.buf,val) : self__.add_BANG_.call(null,self__.buf,val)));
|
|
var take_cbs = (function (){var takers = cljs.core.PersistentVector.EMPTY;
|
|
while(true){
|
|
if((((self__.takes.length > (0))) && ((cljs.core.count(self__.buf) > (0))))){
|
|
var taker = self__.takes.pop();
|
|
if(taker.cljs$core$async$impl$protocols$Handler$active_QMARK_$arity$1(null)){
|
|
var ret = taker.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
var val__$1 = self__.buf.cljs$core$async$impl$protocols$Buffer$remove_BANG_$arity$1(null);
|
|
var G__12547 = cljs.core.conj.cljs$core$IFn$_invoke$arity$2(takers,((function (takers,ret,val__$1,taker,done_QMARK_,closed__$1,this$__$1){
|
|
return (function (){
|
|
return (ret.cljs$core$IFn$_invoke$arity$1 ? ret.cljs$core$IFn$_invoke$arity$1(val__$1) : ret.call(null,val__$1));
|
|
});})(takers,ret,val__$1,taker,done_QMARK_,closed__$1,this$__$1))
|
|
);
|
|
takers = G__12547;
|
|
continue;
|
|
} else {
|
|
var G__12548 = takers;
|
|
takers = G__12548;
|
|
continue;
|
|
}
|
|
} else {
|
|
return takers;
|
|
}
|
|
break;
|
|
}
|
|
})();
|
|
if(done_QMARK_){
|
|
this$__$1.cljs$core$async$impl$channels$MMC$abort$arity$1(null);
|
|
} else {
|
|
}
|
|
|
|
if(cljs.core.seq(take_cbs)){
|
|
var seq__12513_12549 = cljs.core.seq(take_cbs);
|
|
var chunk__12514_12550 = null;
|
|
var count__12515_12551 = (0);
|
|
var i__12516_12552 = (0);
|
|
while(true){
|
|
if((i__12516_12552 < count__12515_12551)){
|
|
var f_12553 = chunk__12514_12550.cljs$core$IIndexed$_nth$arity$2(null,i__12516_12552);
|
|
cljs.core.async.impl.dispatch.run(f_12553);
|
|
|
|
|
|
var G__12554 = seq__12513_12549;
|
|
var G__12555 = chunk__12514_12550;
|
|
var G__12556 = count__12515_12551;
|
|
var G__12557 = (i__12516_12552 + (1));
|
|
seq__12513_12549 = G__12554;
|
|
chunk__12514_12550 = G__12555;
|
|
count__12515_12551 = G__12556;
|
|
i__12516_12552 = G__12557;
|
|
continue;
|
|
} else {
|
|
var temp__5804__auto___12558 = cljs.core.seq(seq__12513_12549);
|
|
if(temp__5804__auto___12558){
|
|
var seq__12513_12559__$1 = temp__5804__auto___12558;
|
|
if(cljs.core.chunked_seq_QMARK_(seq__12513_12559__$1)){
|
|
var c__5568__auto___12560 = cljs.core.chunk_first(seq__12513_12559__$1);
|
|
var G__12561 = cljs.core.chunk_rest(seq__12513_12559__$1);
|
|
var G__12562 = c__5568__auto___12560;
|
|
var G__12563 = cljs.core.count(c__5568__auto___12560);
|
|
var G__12564 = (0);
|
|
seq__12513_12549 = G__12561;
|
|
chunk__12514_12550 = G__12562;
|
|
count__12515_12551 = G__12563;
|
|
i__12516_12552 = G__12564;
|
|
continue;
|
|
} else {
|
|
var f_12565 = cljs.core.first(seq__12513_12559__$1);
|
|
cljs.core.async.impl.dispatch.run(f_12565);
|
|
|
|
|
|
var G__12566 = cljs.core.next(seq__12513_12559__$1);
|
|
var G__12567 = null;
|
|
var G__12568 = (0);
|
|
var G__12569 = (0);
|
|
seq__12513_12549 = G__12566;
|
|
chunk__12514_12550 = G__12567;
|
|
count__12515_12551 = G__12568;
|
|
i__12516_12552 = G__12569;
|
|
continue;
|
|
}
|
|
} else {
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
} else {
|
|
}
|
|
|
|
return cljs.core.async.impl.channels.box(true);
|
|
} else {
|
|
var taker = (function (){while(true){
|
|
var taker = self__.takes.pop();
|
|
if(cljs.core.truth_(taker)){
|
|
if(cljs.core.truth_(taker.cljs$core$async$impl$protocols$Handler$active_QMARK_$arity$1(null))){
|
|
return taker;
|
|
} else {
|
|
continue;
|
|
}
|
|
} else {
|
|
return null;
|
|
}
|
|
break;
|
|
}
|
|
})();
|
|
if(cljs.core.truth_(taker)){
|
|
var take_cb = taker.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
handler.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
|
|
cljs.core.async.impl.dispatch.run((function (){
|
|
return (take_cb.cljs$core$IFn$_invoke$arity$1 ? take_cb.cljs$core$IFn$_invoke$arity$1(val) : take_cb.call(null,val));
|
|
}));
|
|
|
|
return cljs.core.async.impl.channels.box(true);
|
|
} else {
|
|
if((self__.dirty_puts > (64))){
|
|
(self__.dirty_puts = (0));
|
|
|
|
self__.puts.cleanup(cljs.core.async.impl.channels.put_active_QMARK_);
|
|
} else {
|
|
(self__.dirty_puts = (self__.dirty_puts + (1)));
|
|
}
|
|
|
|
if(cljs.core.truth_(handler.cljs$core$async$impl$protocols$Handler$blockable_QMARK_$arity$1(null))){
|
|
if((self__.puts.length < (1024))){
|
|
} else {
|
|
throw (new Error(["Assert failed: ",["No more than ",cljs.core.str.cljs$core$IFn$_invoke$arity$1((1024))," pending puts are allowed on a single channel."," Consider using a windowed buffer."].join(''),"\n","(< (.-length puts) impl/MAX-QUEUE-SIZE)"].join('')));
|
|
}
|
|
|
|
self__.puts.unbounded_unshift((new cljs.core.async.impl.channels.PutBox(handler,val)));
|
|
} else {
|
|
}
|
|
|
|
return null;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.prototype.cljs$core$async$impl$protocols$ReadPort$ = cljs.core.PROTOCOL_SENTINEL);
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.prototype.cljs$core$async$impl$protocols$ReadPort$take_BANG_$arity$2 = (function (this$,handler){
|
|
var self__ = this;
|
|
var this$__$1 = this;
|
|
if((!(handler.cljs$core$async$impl$protocols$Handler$active_QMARK_$arity$1(null)))){
|
|
return null;
|
|
} else {
|
|
if((((!((self__.buf == null)))) && ((cljs.core.count(self__.buf) > (0))))){
|
|
var temp__5802__auto__ = handler.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
if(cljs.core.truth_(temp__5802__auto__)){
|
|
var take_cb = temp__5802__auto__;
|
|
var val = self__.buf.cljs$core$async$impl$protocols$Buffer$remove_BANG_$arity$1(null);
|
|
var vec__12519 = ((((cljs.core.not(self__.buf.cljs$core$async$impl$protocols$Buffer$full_QMARK_$arity$1(null))) && ((self__.puts.length > (0)))))?(function (){var cbs = cljs.core.PersistentVector.EMPTY;
|
|
while(true){
|
|
var putter = self__.puts.pop();
|
|
var put_handler = putter.handler;
|
|
var val__$1 = putter.val;
|
|
var cb = (function (){var and__5043__auto__ = put_handler.cljs$core$async$impl$protocols$Handler$active_QMARK_$arity$1(null);
|
|
if(and__5043__auto__){
|
|
return put_handler.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
} else {
|
|
return and__5043__auto__;
|
|
}
|
|
})();
|
|
var cbs__$1 = (cljs.core.truth_(cb)?cljs.core.conj.cljs$core$IFn$_invoke$arity$2(cbs,cb):cbs);
|
|
var done_QMARK_ = (cljs.core.truth_(cb)?cljs.core.reduced_QMARK_((self__.add_BANG_.cljs$core$IFn$_invoke$arity$2 ? self__.add_BANG_.cljs$core$IFn$_invoke$arity$2(self__.buf,val__$1) : self__.add_BANG_.call(null,self__.buf,val__$1))):null);
|
|
if(((cljs.core.not(done_QMARK_)) && (((cljs.core.not(self__.buf.cljs$core$async$impl$protocols$Buffer$full_QMARK_$arity$1(null))) && ((self__.puts.length > (0))))))){
|
|
var G__12572 = cbs__$1;
|
|
cbs = G__12572;
|
|
continue;
|
|
} else {
|
|
return new cljs.core.PersistentVector(null, 2, 5, cljs.core.PersistentVector.EMPTY_NODE, [done_QMARK_,cbs__$1], null);
|
|
}
|
|
break;
|
|
}
|
|
})():null);
|
|
var done_QMARK_ = cljs.core.nth.cljs$core$IFn$_invoke$arity$3(vec__12519,(0),null);
|
|
var cbs = cljs.core.nth.cljs$core$IFn$_invoke$arity$3(vec__12519,(1),null);
|
|
if(cljs.core.truth_(done_QMARK_)){
|
|
this$__$1.cljs$core$async$impl$channels$MMC$abort$arity$1(null);
|
|
} else {
|
|
}
|
|
|
|
var seq__12525_12573 = cljs.core.seq(cbs);
|
|
var chunk__12526_12574 = null;
|
|
var count__12527_12575 = (0);
|
|
var i__12528_12576 = (0);
|
|
while(true){
|
|
if((i__12528_12576 < count__12527_12575)){
|
|
var cb_12577 = chunk__12526_12574.cljs$core$IIndexed$_nth$arity$2(null,i__12528_12576);
|
|
cljs.core.async.impl.dispatch.run(((function (seq__12525_12573,chunk__12526_12574,count__12527_12575,i__12528_12576,cb_12577,val,vec__12519,done_QMARK_,cbs,take_cb,temp__5802__auto__,this$__$1){
|
|
return (function (){
|
|
return (cb_12577.cljs$core$IFn$_invoke$arity$1 ? cb_12577.cljs$core$IFn$_invoke$arity$1(true) : cb_12577.call(null,true));
|
|
});})(seq__12525_12573,chunk__12526_12574,count__12527_12575,i__12528_12576,cb_12577,val,vec__12519,done_QMARK_,cbs,take_cb,temp__5802__auto__,this$__$1))
|
|
);
|
|
|
|
|
|
var G__12578 = seq__12525_12573;
|
|
var G__12579 = chunk__12526_12574;
|
|
var G__12580 = count__12527_12575;
|
|
var G__12581 = (i__12528_12576 + (1));
|
|
seq__12525_12573 = G__12578;
|
|
chunk__12526_12574 = G__12579;
|
|
count__12527_12575 = G__12580;
|
|
i__12528_12576 = G__12581;
|
|
continue;
|
|
} else {
|
|
var temp__5804__auto___12582 = cljs.core.seq(seq__12525_12573);
|
|
if(temp__5804__auto___12582){
|
|
var seq__12525_12583__$1 = temp__5804__auto___12582;
|
|
if(cljs.core.chunked_seq_QMARK_(seq__12525_12583__$1)){
|
|
var c__5568__auto___12584 = cljs.core.chunk_first(seq__12525_12583__$1);
|
|
var G__12585 = cljs.core.chunk_rest(seq__12525_12583__$1);
|
|
var G__12586 = c__5568__auto___12584;
|
|
var G__12587 = cljs.core.count(c__5568__auto___12584);
|
|
var G__12588 = (0);
|
|
seq__12525_12573 = G__12585;
|
|
chunk__12526_12574 = G__12586;
|
|
count__12527_12575 = G__12587;
|
|
i__12528_12576 = G__12588;
|
|
continue;
|
|
} else {
|
|
var cb_12589 = cljs.core.first(seq__12525_12583__$1);
|
|
cljs.core.async.impl.dispatch.run(((function (seq__12525_12573,chunk__12526_12574,count__12527_12575,i__12528_12576,cb_12589,seq__12525_12583__$1,temp__5804__auto___12582,val,vec__12519,done_QMARK_,cbs,take_cb,temp__5802__auto__,this$__$1){
|
|
return (function (){
|
|
return (cb_12589.cljs$core$IFn$_invoke$arity$1 ? cb_12589.cljs$core$IFn$_invoke$arity$1(true) : cb_12589.call(null,true));
|
|
});})(seq__12525_12573,chunk__12526_12574,count__12527_12575,i__12528_12576,cb_12589,seq__12525_12583__$1,temp__5804__auto___12582,val,vec__12519,done_QMARK_,cbs,take_cb,temp__5802__auto__,this$__$1))
|
|
);
|
|
|
|
|
|
var G__12590 = cljs.core.next(seq__12525_12583__$1);
|
|
var G__12591 = null;
|
|
var G__12592 = (0);
|
|
var G__12593 = (0);
|
|
seq__12525_12573 = G__12590;
|
|
chunk__12526_12574 = G__12591;
|
|
count__12527_12575 = G__12592;
|
|
i__12528_12576 = G__12593;
|
|
continue;
|
|
}
|
|
} else {
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
|
|
return cljs.core.async.impl.channels.box(val);
|
|
} else {
|
|
return null;
|
|
}
|
|
} else {
|
|
var putter = (function (){while(true){
|
|
var putter = self__.puts.pop();
|
|
if(cljs.core.truth_(putter)){
|
|
if(cljs.core.async.impl.protocols.active_QMARK_(putter.handler)){
|
|
return putter;
|
|
} else {
|
|
continue;
|
|
}
|
|
} else {
|
|
return null;
|
|
}
|
|
break;
|
|
}
|
|
})();
|
|
if(cljs.core.truth_(putter)){
|
|
var put_cb = cljs.core.async.impl.protocols.commit(putter.handler);
|
|
handler.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
|
|
cljs.core.async.impl.dispatch.run((function (){
|
|
return (put_cb.cljs$core$IFn$_invoke$arity$1 ? put_cb.cljs$core$IFn$_invoke$arity$1(true) : put_cb.call(null,true));
|
|
}));
|
|
|
|
return cljs.core.async.impl.channels.box(putter.val);
|
|
} else {
|
|
if(cljs.core.truth_(self__.closed)){
|
|
if(cljs.core.truth_(self__.buf)){
|
|
(self__.add_BANG_.cljs$core$IFn$_invoke$arity$1 ? self__.add_BANG_.cljs$core$IFn$_invoke$arity$1(self__.buf) : self__.add_BANG_.call(null,self__.buf));
|
|
} else {
|
|
}
|
|
|
|
if(cljs.core.truth_((function (){var and__5043__auto__ = handler.cljs$core$async$impl$protocols$Handler$active_QMARK_$arity$1(null);
|
|
if(cljs.core.truth_(and__5043__auto__)){
|
|
return handler.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
} else {
|
|
return and__5043__auto__;
|
|
}
|
|
})())){
|
|
var has_val = (function (){var and__5043__auto__ = self__.buf;
|
|
if(cljs.core.truth_(and__5043__auto__)){
|
|
return (cljs.core.count(self__.buf) > (0));
|
|
} else {
|
|
return and__5043__auto__;
|
|
}
|
|
})();
|
|
var val = (cljs.core.truth_(has_val)?self__.buf.cljs$core$async$impl$protocols$Buffer$remove_BANG_$arity$1(null):null);
|
|
return cljs.core.async.impl.channels.box(val);
|
|
} else {
|
|
return null;
|
|
}
|
|
} else {
|
|
if((self__.dirty_takes > (64))){
|
|
(self__.dirty_takes = (0));
|
|
|
|
self__.takes.cleanup(cljs.core.async.impl.protocols.active_QMARK_);
|
|
} else {
|
|
(self__.dirty_takes = (self__.dirty_takes + (1)));
|
|
}
|
|
|
|
if(cljs.core.truth_(handler.cljs$core$async$impl$protocols$Handler$blockable_QMARK_$arity$1(null))){
|
|
if((self__.takes.length < (1024))){
|
|
} else {
|
|
throw (new Error(["Assert failed: ",["No more than ",cljs.core.str.cljs$core$IFn$_invoke$arity$1((1024))," pending takes are allowed on a single channel."].join(''),"\n","(< (.-length takes) impl/MAX-QUEUE-SIZE)"].join('')));
|
|
}
|
|
|
|
self__.takes.unbounded_unshift(handler);
|
|
} else {
|
|
}
|
|
|
|
return null;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.prototype.cljs$core$async$impl$protocols$Channel$ = cljs.core.PROTOCOL_SENTINEL);
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.prototype.cljs$core$async$impl$protocols$Channel$closed_QMARK_$arity$1 = (function (_){
|
|
var self__ = this;
|
|
var ___$1 = this;
|
|
return self__.closed;
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.prototype.cljs$core$async$impl$protocols$Channel$close_BANG_$arity$1 = (function (this$){
|
|
var self__ = this;
|
|
var this$__$1 = this;
|
|
if(self__.closed){
|
|
return null;
|
|
} else {
|
|
(self__.closed = true);
|
|
|
|
if(cljs.core.truth_((function (){var and__5043__auto__ = self__.buf;
|
|
if(cljs.core.truth_(and__5043__auto__)){
|
|
return (self__.puts.length === (0));
|
|
} else {
|
|
return and__5043__auto__;
|
|
}
|
|
})())){
|
|
(self__.add_BANG_.cljs$core$IFn$_invoke$arity$1 ? self__.add_BANG_.cljs$core$IFn$_invoke$arity$1(self__.buf) : self__.add_BANG_.call(null,self__.buf));
|
|
} else {
|
|
}
|
|
|
|
while(true){
|
|
var taker_12594 = self__.takes.pop();
|
|
if((taker_12594 == null)){
|
|
} else {
|
|
if(taker_12594.cljs$core$async$impl$protocols$Handler$active_QMARK_$arity$1(null)){
|
|
var take_cb_12595 = taker_12594.cljs$core$async$impl$protocols$Handler$commit$arity$1(null);
|
|
var val_12596 = (cljs.core.truth_((function (){var and__5043__auto__ = self__.buf;
|
|
if(cljs.core.truth_(and__5043__auto__)){
|
|
return (cljs.core.count(self__.buf) > (0));
|
|
} else {
|
|
return and__5043__auto__;
|
|
}
|
|
})())?self__.buf.cljs$core$async$impl$protocols$Buffer$remove_BANG_$arity$1(null):null);
|
|
cljs.core.async.impl.dispatch.run(((function (take_cb_12595,val_12596,taker_12594,this$__$1){
|
|
return (function (){
|
|
return (take_cb_12595.cljs$core$IFn$_invoke$arity$1 ? take_cb_12595.cljs$core$IFn$_invoke$arity$1(val_12596) : take_cb_12595.call(null,val_12596));
|
|
});})(take_cb_12595,val_12596,taker_12594,this$__$1))
|
|
);
|
|
} else {
|
|
}
|
|
|
|
continue;
|
|
}
|
|
break;
|
|
}
|
|
|
|
if(cljs.core.truth_(self__.buf)){
|
|
self__.buf.cljs$core$async$impl$protocols$Buffer$close_buf_BANG_$arity$1(null);
|
|
} else {
|
|
}
|
|
|
|
return null;
|
|
}
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.getBasis = (function (){
|
|
return new cljs.core.PersistentVector(null, 7, 5, cljs.core.PersistentVector.EMPTY_NODE, [new cljs.core.Symbol(null,"takes","takes",298247964,null),cljs.core.with_meta(new cljs.core.Symbol(null,"dirty-takes","dirty-takes",575642138,null),new cljs.core.PersistentArrayMap(null, 1, [new cljs.core.Keyword(null,"mutable","mutable",875778266),true], null)),new cljs.core.Symbol(null,"puts","puts",-1883877054,null),cljs.core.with_meta(new cljs.core.Symbol(null,"dirty-puts","dirty-puts",57041148,null),new cljs.core.PersistentArrayMap(null, 1, [new cljs.core.Keyword(null,"mutable","mutable",875778266),true], null)),cljs.core.with_meta(new cljs.core.Symbol(null,"buf","buf",1426618187,null),new cljs.core.PersistentArrayMap(null, 1, [new cljs.core.Keyword(null,"tag","tag",-1290361223),new cljs.core.Symbol(null,"not-native","not-native",-236392494,null)], null)),cljs.core.with_meta(new cljs.core.Symbol(null,"closed","closed",720856168,null),new cljs.core.PersistentArrayMap(null, 1, [new cljs.core.Keyword(null,"mutable","mutable",875778266),true], null)),new cljs.core.Symbol(null,"add!","add!",2046056845,null)], null);
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.cljs$lang$type = true);
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.cljs$lang$ctorStr = "cljs.core.async.impl.channels/ManyToManyChannel");
|
|
|
|
(cljs.core.async.impl.channels.ManyToManyChannel.cljs$lang$ctorPrWriter = (function (this__5330__auto__,writer__5331__auto__,opt__5332__auto__){
|
|
return cljs.core._write(writer__5331__auto__,"cljs.core.async.impl.channels/ManyToManyChannel");
|
|
}));
|
|
|
|
/**
|
|
* Positional factory function for cljs.core.async.impl.channels/ManyToManyChannel.
|
|
*/
|
|
cljs.core.async.impl.channels.__GT_ManyToManyChannel = (function cljs$core$async$impl$channels$__GT_ManyToManyChannel(takes,dirty_takes,puts,dirty_puts,buf,closed,add_BANG_){
|
|
return (new cljs.core.async.impl.channels.ManyToManyChannel(takes,dirty_takes,puts,dirty_puts,buf,closed,add_BANG_));
|
|
});
|
|
|
|
cljs.core.async.impl.channels.ex_handler = (function cljs$core$async$impl$channels$ex_handler(ex){
|
|
console.log(ex);
|
|
|
|
return null;
|
|
});
|
|
cljs.core.async.impl.channels.handle = (function cljs$core$async$impl$channels$handle(buf,exh,t){
|
|
var else$ = (function (){var fexpr__12531 = (function (){var or__5045__auto__ = exh;
|
|
if(cljs.core.truth_(or__5045__auto__)){
|
|
return or__5045__auto__;
|
|
} else {
|
|
return cljs.core.async.impl.channels.ex_handler;
|
|
}
|
|
})();
|
|
return (fexpr__12531.cljs$core$IFn$_invoke$arity$1 ? fexpr__12531.cljs$core$IFn$_invoke$arity$1(t) : fexpr__12531.call(null,t));
|
|
})();
|
|
if((else$ == null)){
|
|
return buf;
|
|
} else {
|
|
return cljs.core.async.impl.protocols.add_BANG_.cljs$core$IFn$_invoke$arity$2(buf,else$);
|
|
}
|
|
});
|
|
cljs.core.async.impl.channels.chan = (function cljs$core$async$impl$channels$chan(var_args){
|
|
var G__12534 = arguments.length;
|
|
switch (G__12534) {
|
|
case 1:
|
|
return cljs.core.async.impl.channels.chan.cljs$core$IFn$_invoke$arity$1((arguments[(0)]));
|
|
|
|
break;
|
|
case 2:
|
|
return cljs.core.async.impl.channels.chan.cljs$core$IFn$_invoke$arity$2((arguments[(0)]),(arguments[(1)]));
|
|
|
|
break;
|
|
case 3:
|
|
return cljs.core.async.impl.channels.chan.cljs$core$IFn$_invoke$arity$3((arguments[(0)]),(arguments[(1)]),(arguments[(2)]));
|
|
|
|
break;
|
|
default:
|
|
throw (new Error(["Invalid arity: ",cljs.core.str.cljs$core$IFn$_invoke$arity$1(arguments.length)].join('')));
|
|
|
|
}
|
|
});
|
|
|
|
(cljs.core.async.impl.channels.chan.cljs$core$IFn$_invoke$arity$1 = (function (buf){
|
|
return cljs.core.async.impl.channels.chan.cljs$core$IFn$_invoke$arity$2(buf,null);
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.chan.cljs$core$IFn$_invoke$arity$2 = (function (buf,xform){
|
|
return cljs.core.async.impl.channels.chan.cljs$core$IFn$_invoke$arity$3(buf,xform,null);
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.chan.cljs$core$IFn$_invoke$arity$3 = (function (buf,xform,exh){
|
|
return (new cljs.core.async.impl.channels.ManyToManyChannel(cljs.core.async.impl.buffers.ring_buffer((32)),(0),cljs.core.async.impl.buffers.ring_buffer((32)),(0),buf,false,(function (){var add_BANG_ = (cljs.core.truth_(xform)?(xform.cljs$core$IFn$_invoke$arity$1 ? xform.cljs$core$IFn$_invoke$arity$1(cljs.core.async.impl.protocols.add_BANG_) : xform.call(null,cljs.core.async.impl.protocols.add_BANG_)):cljs.core.async.impl.protocols.add_BANG_);
|
|
return (function() {
|
|
var G__12598 = null;
|
|
var G__12598__1 = (function (buf__$1){
|
|
try{return (add_BANG_.cljs$core$IFn$_invoke$arity$1 ? add_BANG_.cljs$core$IFn$_invoke$arity$1(buf__$1) : add_BANG_.call(null,buf__$1));
|
|
}catch (e12536){var t = e12536;
|
|
return cljs.core.async.impl.channels.handle(buf__$1,exh,t);
|
|
}});
|
|
var G__12598__2 = (function (buf__$1,val){
|
|
try{return (add_BANG_.cljs$core$IFn$_invoke$arity$2 ? add_BANG_.cljs$core$IFn$_invoke$arity$2(buf__$1,val) : add_BANG_.call(null,buf__$1,val));
|
|
}catch (e12537){var t = e12537;
|
|
return cljs.core.async.impl.channels.handle(buf__$1,exh,t);
|
|
}});
|
|
G__12598 = function(buf__$1,val){
|
|
switch(arguments.length){
|
|
case 1:
|
|
return G__12598__1.call(this,buf__$1);
|
|
case 2:
|
|
return G__12598__2.call(this,buf__$1,val);
|
|
}
|
|
throw(new Error('Invalid arity: ' + arguments.length));
|
|
};
|
|
G__12598.cljs$core$IFn$_invoke$arity$1 = G__12598__1;
|
|
G__12598.cljs$core$IFn$_invoke$arity$2 = G__12598__2;
|
|
return G__12598;
|
|
})()
|
|
})()));
|
|
}));
|
|
|
|
(cljs.core.async.impl.channels.chan.cljs$lang$maxFixedArity = 3);
|
|
|
|
|
|
//# sourceMappingURL=cljs.core.async.impl.channels.js.map
|