v0.1.70

src/concepts/ownership/ownership.mode.ts

@@ -65,7 +65,6 @@ export const ownershipMode: Mode = (
             finalMode([nextAction, concepts, action$, concepts$]);
           } else {
           // This assumes that the Strategy is accounting for the Block
-            // console.log('Check Action Failed1', action);
             [concepts, action] = checkIn(concepts, action);
             const nextAction = strategyFailed(
               strategy,

src/concepts/ownership/ownership.principle.ts

@@ -40,7 +40,6 @@ export const ownershipPrinciple: PrincipleFunction = (
   const plan = concepts$.plan('ownership Principle Plan', [
     stageWaitForOpenThenIterate(() => axiumRegisterStagePlanner({conceptName: ownershipName, stagePlanner: plan})),
     createStage((cpts, _) => {
-      console.log('HIT');
       let concepts = cpts;
       let ownershipState = selectUnifiedState<OwnershipState>(concepts, semaphore);
       if (ownershipState?.initialized) {

src/model/actionController.ts

@@ -54,7 +54,6 @@ export class ActionController extends Subject<[Action, boolean]> {
    * Fires once and then completes.
    */
   fire(action: Action) {
-    console.log('FIRE!', action.type);
     if (!this.closed) {
       if (!this.expired && this.timer) {
         clearTimeout(this.timer);

src/model/axium.ts

@@ -65,7 +65,6 @@ export const blockingMethodSubscription = (concepts: Concepts, tail: Action[], a
 };
 
 export const defaultMethodSubscription = (concepts: Concepts, tail: Action[], action$: Subject<Action>, action: Action, async: boolean) => {
-  console.log('HITTING', action, async);
   if (
     action.strategy &&
     // Logical Determination: axiumConcludeType
@@ -183,7 +182,6 @@ export function createAxium(
     .subscribe(([action, _concepts]: [Action, Concepts]) => {
       // Would be notifying methods
       const _axiumState = _concepts[0].state as AxiumState;
-      // console.log('CHECK QUES', _axiumState.head, _axiumState.body, _axiumState.tail);
       if (_axiumState.head.length === 0) {
         _axiumState.head.push(action);
         if (_axiumState.tailTimer.length > 0) {
@@ -194,11 +192,10 @@ export function createAxium(
         }
         const modeIndex = _axiumState.modeIndex;
         if (getAxiumState(_concepts).logActionStream) {
-          console.log('CHECK ACTION STREAM', action.type, action.payload, action.semaphore, action.strategy?.topic);
+          console.log('ACTION STREAM: ', action.type, action.payload, action.semaphore, action.strategy?.topic);
         }
         const modes = _concepts[0].mode as Mode[];
         const mode = modes[modeIndex] as Mode;
-        // console.log('STREAM', action, mode);
         mode([action, _concepts, _axiumState.action$, _axiumState.concepts$]);
         _axiumState.head.shift();
         if (_axiumState.body.length === 0) {

src/model/method.ts

@@ -231,10 +231,6 @@ export const createAsyncMethodBufferWithConcepts =
           asyncMethodWithConcepts(controller, action, concepts, semaphore);
         });
       }),
-      // map(([action, boolean], i) => {
-      //   console.log('CHECK THIS MAP', action, boolean, i);
-      //   return [action, boolean];
-      // }),
     );
     defaultMethod.toString = () => ('Async Buffer Method with Concepts');
     return [defaultMethod, defaultSubject];

src/model/priority.ts

@@ -8,7 +8,6 @@ import { Action } from './action';
 
 // Is only called if action has priority
 const fillBucket = (body: Action[], bucket: Action[], action: Action, _added = false) => {
-  // console.log('FILL BUCKET', body, bucket, action, _added);
   let added = _added;
   const drop = body.shift();
   if (drop) {
@@ -43,7 +42,6 @@ const emptyBucket = (body: Action[], bucket: Action[]) => {
 
 export const handlePriority = (axiumState: AxiumState, action: Action) => {
   const body = axiumState.body;
-  // console.log('HIT HANDLE PRIORITY', body[0],);
   if (body[0] && body[0].priority !== undefined) {
     const bucket: Action[] = [];
     fillBucket(body, bucket, action);

src/model/stagePlanner.ts

@@ -772,14 +772,12 @@ export class UnifiedSubject extends Subject<Concepts> {
         });
       }
     }
-    // console.log('CHECK BLOCKING', blocking, this.ques);
     const notification = (id: number) => {
       const ready = notifyIds.get(id);
       const plan = this.currentPlans.get(id);
       if (plan && ready !== undefined) {
         this.nextPlan(plan as Plan, ready);
       } else if (plan && plan.stages[plan.stage].firstRun) {
-        // console.log('FIRST RUN: ', plan.title);
         plan.stages[plan.stage].firstRun = false;
         this.nextPlan(plan as Plan, []);
       }
@@ -807,7 +805,6 @@ export class UnifiedSubject extends Subject<Concepts> {
   }
 
   next(concepts: Concepts) {
-    // console.log('NEXT', getAxiumState(concepts).tail);
     if (!this.closed) {
       this.handleChange(concepts);
       // We notify subs last to encourage actions being acted upon observations

src/test/bufferMethods/qualities/asyncBufferMultiplyByCountFromConceptsAction.quality.ts

@@ -20,7 +20,6 @@ export const [
   reducer: defaultReducer,
   methodCreator: (c, s) => createAsyncMethodBufferWithConcepts((controller, _, concepts) => {
     setTimeout(() => {
-      console.log('TIMEOUT ASYNC');
       const counterState = selectState<CounterState>(concepts, counterName);
       controller.fire(strategyBegin(createStrategy({
         initialNode: createActionNode(counterMultiply({

src/test/newPlanOptions/qualities/isReady.quality.ts

@@ -11,7 +11,6 @@ export const experimentPlanOptionsIsReadyType = 'experimentPlanOptions is ready'
 export const experimentPlanOptionsIsReady = act.prepareActionCreator(experimentPlanOptionsIsReadyType);
 
 function experimentPlanOptionsIsReadyReducer(state: ExperimentPlanOptionsState, action: Action): ExperimentPlanOptionsState {
-  console.log('EXPERIMENT IS READY!!!');
   return {
     ...state,
     ready: true

src/test/priority/qualities/isReady.quality.ts

@@ -11,7 +11,6 @@ export const experimentPriorityIsReadyType = 'experimentPriority is ready';
 export const experimentPriorityIsReady = act.prepareActionCreator(experimentPriorityIsReadyType);
 
 function experimentPriorityIsReadyReducer(state: ExperimentPriorityState, action: Action): ExperimentPriorityState {
-  console.log('EXPERIMENT IS READY!!!');
   return {
     ...state,
     ready: true