New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@devvit/multiplatform

Package Overview
Dependencies
Maintainers
0
Versions
67
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@devvit/multiplatform - npm Package Compare versions

Comparing version 0.0.1-20241119-bd8b7759 to 0.0.1-20241213-bc413934

7

kotlin/ui-shared-shared.d.ts

@@ -75,5 +75,6 @@ type Nullable<T> = T | null | undefined

export declare class BaseTrace {
constructor(spanName: string, durationMs: string);
constructor(spanName: string, startTimeMs: number, endTimeMs: number);
get spanName(): string;
get durationMs(): string;
get startTimeMs(): number;
get endTimeMs(): number;
}

@@ -100,3 +101,3 @@ export declare class ErrorInfo {

export declare class RuntimeTrace extends BaseTrace {
constructor(spanName: string, durationMs: string, intent: string, target: string, eventCount: number);
constructor(spanName: string, startTimeMs: number, endTimeMs: number, intent: string, target: string, eventCount: number);
get intent(): string;

@@ -103,0 +104,0 @@ get target(): string;

@@ -35,6 +35,4 @@ import {

getStringHashCode26igk1bx568vk as getStringHashCode,
Long2qws0ah9gnpki as Long,
ArrayList_init_$Create$1s1wkrw82c0iw as ArrayList_init_$Create$_0,
to2cs3ny02qtbcb as to,
numberToLong1a4cndvg6c52s as numberToLong,
} from './kotlin-kotlin-stdlib.js';

@@ -74,6 +72,6 @@ //region block: imports

function OneAtATimeAssembler(logger, timerDelegate) {
this.e7_1 = logger;
this.f7_1 = timerDelegate;
this.d7_1 = logger;
this.e7_1 = timerDelegate;
}
protoOf(OneAtATimeAssembler).g7 = function (queue, mode) {
protoOf(OneAtATimeAssembler).f7 = function (queue, mode) {
var tmp;

@@ -83,4 +81,4 @@ if (queue.t()) {

} else {
var timerDefinitions = this.f7_1.list();
var event = queue.c6();
var timerDefinitions = this.e7_1.list();
var event = queue.b6();
while (isUseIntervalEvent(event)) {

@@ -95,3 +93,3 @@ // Inline function 'kotlin.collections.forEach' call

if (element.id === event.hook) {
this.e7_1.i7(['' + mode + ' building batch of ', event]);
this.d7_1.h7(['' + mode + ' building batch of ', event]);
return listOf(event);

@@ -102,3 +100,3 @@ }

if (!queue.t()) {
event = queue.c6();
event = queue.b6();
} else {

@@ -108,3 +106,3 @@ return emptyList();

}
this.e7_1.i7(['' + mode + ' building batch of ', event]);
this.d7_1.h7(['' + mode + ' building batch of ', event]);
tmp = listOf(event);

@@ -115,6 +113,6 @@ }

function AllAtOnceAssembler(logger, timerDelegate) {
this.j7_1 = logger;
this.k7_1 = timerDelegate;
this.i7_1 = logger;
this.j7_1 = timerDelegate;
}
protoOf(AllAtOnceAssembler).g7 = function (queue, mode) {
protoOf(AllAtOnceAssembler).f7 = function (queue, mode) {
var tmp;

@@ -124,3 +122,3 @@ if (queue.t()) {

} else {
var timerDefinitions = this.k7_1.list();
var timerDefinitions = this.j7_1.list();
// Inline function 'kotlin.collections.filter' call

@@ -168,4 +166,4 @@ // Inline function 'kotlin.collections.filterTo' call

var batch = destination;
queue.f6();
this.j7_1.i7(['' + mode + ' building batch of ', batch]);
queue.e6();
this.i7_1.h7(['' + mode + ' building batch of ', batch]);
tmp = batch;

@@ -184,21 +182,21 @@ }

}
protoOf(SubscribeCallbackParams).l7 = function () {
protoOf(SubscribeCallbackParams).k7 = function () {
return this.request;
};
protoOf(SubscribeCallbackParams).m7 = function () {
protoOf(SubscribeCallbackParams).l7 = function () {
return this.response;
};
protoOf(SubscribeCallbackParams).n7 = function () {
protoOf(SubscribeCallbackParams).m7 = function () {
return this.mode;
};
protoOf(SubscribeCallbackParams).c7 = function () {
protoOf(SubscribeCallbackParams).b7 = function () {
return this.request;
};
protoOf(SubscribeCallbackParams).d7 = function () {
protoOf(SubscribeCallbackParams).c7 = function () {
return this.response;
};
protoOf(SubscribeCallbackParams).o7 = function () {
protoOf(SubscribeCallbackParams).n7 = function () {
return this.mode;
};
protoOf(SubscribeCallbackParams).p7 = function (request, response, mode) {
protoOf(SubscribeCallbackParams).o7 = function (request, response, mode) {
return new SubscribeCallbackParams(request, response, mode);

@@ -210,3 +208,3 @@ };

mode = mode === VOID ? this.mode : mode;
return this.p7(request, response, mode);
return this.o7(request, response, mode);
};

@@ -281,11 +279,11 @@ protoOf(SubscribeCallbackParams).toString = function () {

function Callback(success, failure) {
this.s7_1 = success;
this.t7_1 = failure;
this.r7_1 = success;
this.s7_1 = failure;
}
protoOf(Callback).toString = function () {
return 'Callback(success=' + this.s7_1 + ', failure=' + this.t7_1 + ')';
return 'Callback(success=' + this.r7_1 + ', failure=' + this.s7_1 + ')';
};
protoOf(Callback).hashCode = function () {
var result = hashCode(this.s7_1);
result = imul(result, 31) + hashCode(this.t7_1) | 0;
var result = hashCode(this.r7_1);
result = imul(result, 31) + hashCode(this.s7_1) | 0;
return result;

@@ -299,10 +297,10 @@ };

var tmp0_other_with_cast = other instanceof Callback ? other : THROW_CCE();
if (!equals(this.r7_1, tmp0_other_with_cast.r7_1))
return false;
if (!equals(this.s7_1, tmp0_other_with_cast.s7_1))
return false;
if (!equals(this.t7_1, tmp0_other_with_cast.t7_1))
return false;
return true;
};
function _get_assembler__abkpkh($this) {
var tmp = $this.c8_1;
var tmp = $this.b8_1;
if (!(tmp == null))

@@ -315,3 +313,3 @@ return tmp;

function _get_local__en0sai($this) {
var tmp = $this.j8_1;
var tmp = $this.i8_1;
if (!(tmp == null))

@@ -324,3 +322,3 @@ return tmp;

function _get_remote__f6fj3v($this) {
var tmp = $this.k8_1;
var tmp = $this.j8_1;
if (!(tmp == null))

@@ -333,3 +331,3 @@ return tmp;

function _get_timers__g2d3wd($this) {
var tmp = $this.l8_1;
var tmp = $this.k8_1;
if (!(tmp == null))

@@ -343,5 +341,5 @@ return tmp;

resetSpeculation($this);
$this.q8_1 = true;
$this.z7_1.i7(['recalculateSpeculativeWork']);
var iterator = $this.d8_1.l();
$this.p8_1 = true;
$this.y7_1.h7(['recalculateSpeculativeWork']);
var iterator = $this.c8_1.l();
var index = 0;

@@ -356,18 +354,18 @@ $l$loop_1: while (iterator.m()) {

continue $l$loop_1;
if ($this.f8_1.x5_1 > 10)
if ($this.e8_1.w5_1 > 10)
break $l$loop_1;
$this.f8_1.i(item);
$this.e8_1.i(item);
}
$this.z7_1.i7(['Speculative queue size: ' + $this.f8_1.x5_1]);
verboseLog($this, $this.f8_1);
$this.y7_1.h7(['Speculative queue size: ' + $this.e8_1.w5_1]);
verboseLog($this, $this.e8_1);
}
function cancelSpeculation($this) {
$this.z7_1.i7(['cancelSpeculation']);
$this.q8_1 = false;
$this.y7_1.h7(['cancelSpeculation']);
$this.p8_1 = false;
resetSpeculation($this);
}
function resetSpeculation($this) {
$this.f8_1.f6();
$this.n8_1 = $this.w7_1.clone($this.state);
$this.o8_1 = $this.o8_1 + 1 | 0;
$this.e8_1.e6();
$this.m8_1 = $this.v7_1.clone($this.state);
$this.n8_1 = $this.n8_1 + 1 | 0;
}

@@ -381,17 +379,17 @@ function processBatch($this, batch, mode) {

if (mode.equals(Mode_SYNC_getInstance()))
$this.g8_1 = true;
var request = $this.v7_1.r8(mode.equals(Mode_SPEC_getInstance()) ? $this.n8_1 : $this.state, batch);
$this.f8_1 = true;
var request = $this.u7_1.q8(mode.equals(Mode_SPEC_getInstance()) ? $this.m8_1 : $this.state, batch);
var runtime = isRemote ? _get_remote__f6fj3v($this) : _get_local__en0sai($this);
var tmp1 = $this.a8_1;
$this.a8_1 = tmp1 + 1 | 0;
var tmp1 = $this.z7_1;
$this.z7_1 = tmp1 + 1 | 0;
var requestId = tmp1;
var intendedGeneration = $this.o8_1;
var processRequestSpan = Tracer_instance.s8('runtime_trace');
var intendedGeneration = $this.n8_1;
var processRequestSpan = Tracer_instance.r8('runtime_trace');
var tmp = DispatcherImpl$processBatch$lambda($this, mode, isRemote, processRequestSpan, batch, requestId, intendedGeneration, request);
var cbs = new Callback(tmp, DispatcherImpl$processBatch$lambda_0($this, mode, isRemote, processRequestSpan, requestId, batch));
// Inline function 'kotlin.collections.set' call
$this.h8_1.i1(requestId, cbs);
$this.z7_1.i7(['Signpost: Handling ' + getRuntimeLogString($this, mode, isRemote) + ' request']);
$this.g8_1.i1(requestId, cbs);
$this.y7_1.h7(['Signpost: Handling ' + getRuntimeLogString($this, mode, isRemote) + ' request']);
verboseLog($this, request);
runtime.handle($this.x7_1, request, cbs.s7_1, cbs.t7_1);
runtime.handle($this.w7_1, request, cbs.r7_1, cbs.s7_1);
}

@@ -402,7 +400,7 @@ function getRuntimeLogString($this, mode, isRemote) {

function reset($this, isResettingTimers) {
$this.q8_1 = $this.p8_1;
$this.g8_1 = false;
$this.state = $this.w7_1.clone($this.m8_1);
$this.e8_1.f6();
$this.d8_1.f6();
$this.p8_1 = $this.o8_1;
$this.f8_1 = false;
$this.state = $this.v7_1.clone($this.l8_1);
$this.d8_1.e6();
$this.c8_1.e6();
_get_local__en0sai($this).reset();

@@ -423,4 +421,4 @@ _get_remote__f6fj3v($this).reset();

var e = $p;
$this.z7_1.t8([e]);
$this.y7_1.errorHandler(e);
$this.y7_1.s8([e]);
$this.x7_1.errorHandler(e);
tmp_0 = default_0;

@@ -435,4 +433,4 @@ } else {

function verboseLog($this, message) {
if ($this.y7_1.featureFlags.isVerboseLoggingEnabled) {
$this.z7_1.i7([message]);
if ($this.x7_1.featureFlags.isVerboseLoggingEnabled) {
$this.y7_1.h7([message]);
}

@@ -451,3 +449,3 @@ }

// Inline function 'kotlin.collections.firstOrNull' call
var tmp0_iterator = this$0.d8_1.l();
var tmp0_iterator = this$0.c8_1.l();
while (tmp0_iterator.m()) {

@@ -469,3 +467,3 @@ var element = tmp0_iterator.o();

// Inline function 'kotlin.collections.firstOrNull' call
var tmp0_iterator_0 = this$0.e8_1.l();
var tmp0_iterator_0 = this$0.d8_1.l();
while (tmp0_iterator_0.m()) {

@@ -488,15 +486,15 @@ var element_0 = tmp0_iterator_0.o();

return function () {
this$0.z7_1.i7(['Signpost: Initializing Dispatcher', $local, $remote]);
this$0.j8_1 = $local;
this$0.k8_1 = $remote;
this$0.l8_1 = $timers;
this$0.y7_1.h7(['Signpost: Initializing Dispatcher', $local, $remote]);
this$0.i8_1 = $local;
this$0.j8_1 = $remote;
this$0.k8_1 = $timers;
var tmp = this$0;
var tmp_0;
if (this$0.y7_1.featureFlags.isUsingEverythingAssembler) {
tmp_0 = new AllAtOnceAssembler(this$0.z7_1, $timers);
if (this$0.x7_1.featureFlags.isUsingEverythingAssembler) {
tmp_0 = new AllAtOnceAssembler(this$0.y7_1, $timers);
} else {
tmp_0 = new OneAtATimeAssembler(this$0.z7_1, $timers);
tmp_0 = new OneAtATimeAssembler(this$0.y7_1, $timers);
}
tmp.c8_1 = tmp_0;
this$0.u8();
tmp.b8_1 = tmp_0;
this$0.t8();
return Unit_instance;

@@ -506,7 +504,7 @@ };

function DispatcherImpl$subscribe$1$1(this$0, $typedCallback) {
this.v8_1 = this$0;
this.w8_1 = $typedCallback;
this.u8_1 = this$0;
this.v8_1 = $typedCallback;
}
protoOf(DispatcherImpl$subscribe$1$1).unsubscribe = function () {
this.v8_1.i8_1.j(this.w8_1);
this.u8_1.h8_1.j(this.v8_1);
};

@@ -516,3 +514,3 @@ function DispatcherImpl$subscribe$lambda($callback, this$0) {

var typedCallback = typeof $callback === 'function' ? $callback : THROW_CCE();
this$0.i8_1.i(typedCallback);
this$0.h8_1.i(typedCallback);
return new DispatcherImpl$subscribe$1$1(this$0, typedCallback);

@@ -523,14 +521,14 @@ };

return function () {
this$0.z7_1.i7(['Signpost: Response success for ' + getRuntimeLogString(this$0, $mode, $isRemote) + ' request']);
this$0.y7_1.h7(['Signpost: Response success for ' + getRuntimeLogString(this$0, $mode, $isRemote) + ' request']);
verboseLog(this$0, $rsp);
$processRequestSpan.a9();
logRuntimeTrace(this$0.y7_1.performanceAnalyticsDelegate, $processRequestSpan, $isRemote, '', $batch.q());
this$0.h8_1.j1($requestId);
$processRequestSpan.z8();
logRuntimeTrace(this$0.x7_1.performanceAnalyticsDelegate, $processRequestSpan, $isRemote, '', $batch.q());
this$0.g8_1.j1($requestId);
var tmp;
if ($mode.equals(Mode_SPEC_getInstance()) ? !(this$0.o8_1 === $intendedGeneration) : false) {
this$0.z7_1.i7(['throwing away stale speculative results']);
if ($mode.equals(Mode_SPEC_getInstance()) ? !(this$0.n8_1 === $intendedGeneration) : false) {
this$0.y7_1.h7(['throwing away stale speculative results']);
return Unit_instance;
}
this$0.z7_1.i7(['Responding to ' + getRuntimeLogString(this$0, $mode, $isRemote) + ' runtime result subscriptions']);
var tmp0_iterator = this$0.i8_1.l();
this$0.y7_1.h7(['Responding to ' + getRuntimeLogString(this$0, $mode, $isRemote) + ' runtime result subscriptions']);
var tmp0_iterator = this$0.h8_1.l();
while (tmp0_iterator.m()) {

@@ -543,16 +541,16 @@ var element = tmp0_iterator.o();

if ($mode.equals(Mode_SYNC_getInstance())) {
this$0.state = this$0.w7_1.merge(this$0.state, $rsp.state);
this$0.g8_1 = false;
this$0.state = this$0.v7_1.merge(this$0.state, $rsp.state);
this$0.f8_1 = false;
tmp_0 = Unit_instance;
} else if ($mode.equals(Mode_SPEC_getInstance())) {
this$0.n8_1 = this$0.w7_1.merge(this$0.n8_1, $rsp.state);
this$0.m8_1 = this$0.v7_1.merge(this$0.m8_1, $rsp.state);
tmp_0 = Unit_instance;
}
this$0.b9(toList($rsp.replay), $mode);
this$0.a9(toList($rsp.replay), $mode);
var tmp_1;
if ($mode.equals(Mode_SYNC_getInstance()) ? this$0.p8_1 : false) {
if ($mode.equals(Mode_SYNC_getInstance()) ? this$0.o8_1 : false) {
recalculateSpeculativeWork(this$0);
tmp_1 = Unit_instance;
}
this$0.u8();
this$0.t8();
return Unit_instance;

@@ -569,11 +567,11 @@ };

return function () {
this$0.z7_1.i7(['Signpost: Response error for ' + getRuntimeLogString(this$0, $mode, $isRemote) + ' request', $err]);
$processRequestSpan.a9();
var tmp = this$0.y7_1.performanceAnalyticsDelegate;
this$0.y7_1.h7(['Signpost: Response error for ' + getRuntimeLogString(this$0, $mode, $isRemote) + ' request', $err]);
$processRequestSpan.z8();
var tmp = this$0.x7_1.performanceAnalyticsDelegate;
var tmp0_elvis_lhs = $err.message;
logRuntimeError(tmp, tmp0_elvis_lhs == null ? 'Request Response Error' + (' with a duration of ' + $processRequestSpan.c9().toString() + 'ms') : tmp0_elvis_lhs, $isRemote, '');
this$0.h8_1.j1($requestId);
logRuntimeError(tmp, tmp0_elvis_lhs == null ? 'Request Response Error' + (' with a duration of ' + $processRequestSpan.b9() + 'ms') : tmp0_elvis_lhs, $isRemote, '');
this$0.g8_1.j1($requestId);
var tmp_0;
if ($mode.equals(Mode_SYNC_getInstance())) {
this$0.g8_1 = false;
this$0.f8_1 = false;
tmp_0 = Unit_instance;

@@ -584,3 +582,3 @@ }

cancelSpeculation(this$0);
this$0.u8();
this$0.t8();
return Unit_instance;

@@ -621,4 +619,4 @@ }

var events = copyToArray(this_2);
this$0.z7_1.i7(arrayConcat([['unretryable events', $err], events]));
tmp_3 = this$0.y7_1.errorHandler($err);
this$0.y7_1.h7(arrayConcat([['unretryable events', $err], events]));
tmp_3 = this$0.x7_1.errorHandler($err);
}

@@ -644,7 +642,7 @@ var tmp_4;

var tmp3_elvis_lhs = replayable.r1(true);
this$0.b9(tmp3_elvis_lhs == null ? emptyList() : tmp3_elvis_lhs, $mode);
if ($mode.equals(Mode_SYNC_getInstance()) ? this$0.p8_1 : false) {
this$0.a9(tmp3_elvis_lhs == null ? emptyList() : tmp3_elvis_lhs, $mode);
if ($mode.equals(Mode_SYNC_getInstance()) ? this$0.o8_1 : false) {
recalculateSpeculativeWork(this$0);
}
this$0.u8();
this$0.t8();
tmp_4 = Unit_instance;

@@ -663,5 +661,5 @@ }

return function () {
this$0.z7_1.i7(arrayConcat([['Signpost: Submitted events'], $events]));
this$0.y7_1.h7(arrayConcat([['Signpost: Submitted events'], $events]));
// Inline function 'kotlin.collections.fold' call
var this_0 = this$0.b8_1;
var this_0 = this$0.a8_1;
var accumulator = toList($events);

@@ -673,3 +671,3 @@ var tmp0_iterator = this_0.l();

var events = accumulator;
accumulator = element.d9(events);
accumulator = element.c9(events);
}

@@ -691,12 +689,12 @@ var filteredEvents = accumulator;

var tmp0_container = new Pair(first, second);
var asyncEvents = tmp0_container.c7();
var syncEvents = tmp0_container.d7();
this$0.e8_1.p(asyncEvents);
this$0.d8_1.p(syncEvents);
var asyncEvents = tmp0_container.b7();
var syncEvents = tmp0_container.c7();
this$0.d8_1.p(asyncEvents);
this$0.c8_1.p(syncEvents);
var tmp;
if (this$0.g8_1 ? this$0.q8_1 : false) {
this$0.f8_1.p(syncEvents);
if (this$0.f8_1 ? this$0.p8_1 : false) {
this$0.e8_1.p(syncEvents);
tmp = Unit_instance;
}
this$0.u8();
this$0.t8();
return Unit_instance;

@@ -713,9 +711,9 @@ };

return function () {
this$0.state = this$0.w7_1.clone($snap.state);
this$0.e8_1.f6();
this$0.state = this$0.v7_1.clone($snap.state);
this$0.d8_1.e6();
var tmp = $snap.asyncQueue;
addAll(this$0.e8_1, isArray(tmp) ? tmp : THROW_CCE());
this$0.d8_1.f6();
addAll(this$0.d8_1, isArray(tmp) ? tmp : THROW_CCE());
this$0.c8_1.e6();
var tmp_0 = $snap.syncQueue;
addAll(this$0.d8_1, isArray(tmp_0) ? tmp_0 : THROW_CCE());
addAll(this$0.c8_1, isArray(tmp_0) ? tmp_0 : THROW_CCE());
cancelSpeculation(this$0);

@@ -731,34 +729,37 @@ _get_local__en0sai(this$0).resume($snap.localSnapshot);

options = options === VOID ? new EmptyOptions() : options;
this.u7_1 = state;
this.v7_1 = requestBuilder;
this.w7_1 = stateOperations;
this.x7_1 = method;
this.y7_1 = options;
this.z7_1 = new NiceLogger(this.y7_1.logger);
this.a8_1 = 0;
this.t7_1 = state;
this.u7_1 = requestBuilder;
this.v7_1 = stateOperations;
this.w7_1 = method;
this.x7_1 = options;
this.y7_1 = new NiceLogger(this.x7_1.logger);
this.z7_1 = 0;
var tmp = this;
var tmp_0 = new LocalEventsDeduper(DispatcherImpl$dedupers$lambda(this), this.z7_1);
tmp.b8_1 = listOf_0([tmp_0, new IntervalEventDeduper(DispatcherImpl$dedupers$lambda_0(this))]);
var tmp_0 = new LocalEventsDeduper(DispatcherImpl$dedupers$lambda(this), this.y7_1);
tmp.a8_1 = listOf_0([tmp_0, new IntervalEventDeduper(DispatcherImpl$dedupers$lambda_0(this))]);
this.c8_1 = ArrayDeque_init_$Create$();
this.d8_1 = ArrayDeque_init_$Create$();
this.e8_1 = ArrayDeque_init_$Create$();
this.f8_1 = ArrayDeque_init_$Create$();
this.g8_1 = false;
this.f8_1 = false;
var tmp_1 = this;
// Inline function 'kotlin.collections.mutableMapOf' call
tmp_1.h8_1 = LinkedHashMap_init_$Create$();
tmp_1.g8_1 = LinkedHashMap_init_$Create$();
var tmp_2 = this;
// Inline function 'kotlin.collections.mutableListOf' call
tmp_2.i8_1 = ArrayList_init_$Create$();
this.m8_1 = this.w7_1.clone(this.state);
this.n8_1 = this.w7_1.clone(this.m8_1);
this.o8_1 = 0;
this.p8_1 = this.y7_1.featureFlags.isSpeculativeExecutionEnabled;
this.q8_1 = this.p8_1;
this.z7_1.i7(['Signpost: Constructed KMP Dispatcher']);
tmp_2.h8_1 = ArrayList_init_$Create$();
this.l8_1 = this.v7_1.clone(this.state);
this.m8_1 = this.v7_1.clone(this.l8_1);
this.n8_1 = 0;
this.o8_1 = this.x7_1.featureFlags.isSpeculativeExecutionEnabled;
this.p8_1 = this.o8_1;
this.y7_1.h7(['Signpost: Constructed KMP Dispatcher']);
}
protoOf(DispatcherImpl).e9 = function (_set____db54di) {
this.u7_1 = _set____db54di;
protoOf(DispatcherImpl).d9 = function (_set____db54di) {
this.t7_1 = _set____db54di;
};
protoOf(DispatcherImpl).e9 = function () {
return this.t7_1;
};
protoOf(DispatcherImpl).f9 = function () {
return this.u7_1;
return this.c8_1;
};

@@ -771,5 +772,2 @@ protoOf(DispatcherImpl).g9 = function () {

};
protoOf(DispatcherImpl).i9 = function () {
return this.f8_1;
};
protoOf(DispatcherImpl).init = function (local, remote, timers) {

@@ -782,28 +780,28 @@ attemptAndCatch(this, Unit_instance, DispatcherImpl$init$lambda(this, local, remote, timers));

};
protoOf(DispatcherImpl).u8 = function () {
this.z7_1.i7(['ticking', 'syncInFlight ' + this.g8_1, 'asyncQueue.size ' + this.e8_1.x5_1, 'syncQueue.size ' + this.d8_1.x5_1, 'speculativeQueue.size ' + this.f8_1.x5_1]);
if ((!_get_local__en0sai(this).isReady() ? !_get_remote__f6fj3v(this).isReady() : false) ? !(this.d8_1.t() ? this.e8_1.t() : false) : false) {
this.z7_1.j9(['ticking with events and no runtime, deferring...']);
protoOf(DispatcherImpl).t8 = function () {
this.y7_1.h7(['ticking', 'syncInFlight ' + this.f8_1, 'asyncQueue.size ' + this.d8_1.w5_1, 'syncQueue.size ' + this.c8_1.w5_1, 'speculativeQueue.size ' + this.e8_1.w5_1]);
if ((!_get_local__en0sai(this).isReady() ? !_get_remote__f6fj3v(this).isReady() : false) ? !(this.c8_1.t() ? this.d8_1.t() : false) : false) {
this.y7_1.i9(['ticking with events and no runtime, deferring...']);
return Unit_instance;
}
if (!this.g8_1) {
var batch = _get_assembler__abkpkh(this).g7(this.d8_1, Mode_SYNC_getInstance());
if (!this.f8_1) {
var batch = _get_assembler__abkpkh(this).f7(this.c8_1, Mode_SYNC_getInstance());
processBatch(this, batch, Mode_SYNC_getInstance());
} else if (this.q8_1) {
var batch_0 = _get_assembler__abkpkh(this).g7(this.f8_1, Mode_SPEC_getInstance());
} else if (this.p8_1) {
var batch_0 = _get_assembler__abkpkh(this).f7(this.e8_1, Mode_SPEC_getInstance());
processBatch(this, batch_0, Mode_SPEC_getInstance());
}
if (!this.e8_1.t()) {
while (!this.e8_1.t()) {
var batch_1 = _get_assembler__abkpkh(this).g7(this.e8_1, Mode_ASYNC_getInstance());
if (!this.d8_1.t()) {
while (!this.d8_1.t()) {
var batch_1 = _get_assembler__abkpkh(this).f7(this.d8_1, Mode_ASYNC_getInstance());
processBatch(this, batch_1, Mode_ASYNC_getInstance());
}
this.u8();
this.t8();
}
};
protoOf(DispatcherImpl).b9 = function (events, fromMode) {
protoOf(DispatcherImpl).a9 = function (events, fromMode) {
if (events.t() ? true : fromMode.equals(Mode_SPEC_getInstance())) {
return Unit_instance;
}
this.z7_1.i7(['replaying ' + events.q() + ' events']);
this.y7_1.h7(['replaying ' + events.q() + ' events']);
verboseLog(this, events);

@@ -834,9 +832,9 @@ // Inline function 'kotlin.collections.groupBy' call

var tmp0_elvis_lhs = grouped.r1(new Pair(true, true));
this.e8_1.e6(0, tmp0_elvis_lhs == null ? emptyList() : tmp0_elvis_lhs);
this.d8_1.d6(0, tmp0_elvis_lhs == null ? emptyList() : tmp0_elvis_lhs);
var tmp1_elvis_lhs = grouped.r1(new Pair(true, false));
this.e8_1.p(tmp1_elvis_lhs == null ? emptyList() : tmp1_elvis_lhs);
this.d8_1.p(tmp1_elvis_lhs == null ? emptyList() : tmp1_elvis_lhs);
var tmp2_elvis_lhs = grouped.r1(new Pair(false, true));
this.d8_1.e6(0, tmp2_elvis_lhs == null ? emptyList() : tmp2_elvis_lhs);
this.c8_1.d6(0, tmp2_elvis_lhs == null ? emptyList() : tmp2_elvis_lhs);
var tmp3_elvis_lhs = grouped.r1(new Pair(false, false));
this.d8_1.p(tmp3_elvis_lhs == null ? emptyList() : tmp3_elvis_lhs);
this.c8_1.p(tmp3_elvis_lhs == null ? emptyList() : tmp3_elvis_lhs);
};

@@ -850,8 +848,8 @@ protoOf(DispatcherImpl).submit = function (events) {

protoOf(DispatcherImpl).snapshot = function () {
var tmp = this.w7_1.clone(this.state);
var tmp = this.v7_1.clone(this.state);
// Inline function 'kotlin.collections.toTypedArray' call
var this_0 = this.d8_1;
var this_0 = this.c8_1;
var tmp_0 = copyToArray(this_0);
// Inline function 'kotlin.collections.toTypedArray' call
var this_1 = this.e8_1;
var this_1 = this.d8_1;
var tmp$ret$1 = copyToArray(this_1);

@@ -873,32 +871,32 @@ return new DispatcherSnapshot(tmp, tmp_0, tmp$ret$1, _get_local__en0sai(this).snapshot(), _get_remote__f6fj3v(this).snapshot(), _get_timers__g2d3wd(this).list());

function EmptyOptions() {
this.k9_1 = new NoOpLogger();
this.j9_1 = new NoOpLogger();
var tmp = this;
tmp.l9_1 = EmptyOptions$errorHandler$lambda;
this.m9_1 = Disabled_instance;
this.n9_1 = new NoOpPerformanceAnalyticsDelegate();
tmp.k9_1 = EmptyOptions$errorHandler$lambda;
this.l9_1 = Disabled_instance;
this.m9_1 = new NoOpPerformanceAnalyticsDelegate();
}
protoOf(EmptyOptions).o9 = function (_set____db54di) {
protoOf(EmptyOptions).n9 = function (_set____db54di) {
this.j9_1 = _set____db54di;
};
protoOf(EmptyOptions).o9 = function () {
return this.j9_1;
};
protoOf(EmptyOptions).p9 = function (_set____db54di) {
this.k9_1 = _set____db54di;
};
protoOf(EmptyOptions).p9 = function () {
protoOf(EmptyOptions).q9 = function () {
return this.k9_1;
};
protoOf(EmptyOptions).q9 = function (_set____db54di) {
protoOf(EmptyOptions).r9 = function (_set____db54di) {
this.l9_1 = _set____db54di;
};
protoOf(EmptyOptions).r9 = function () {
protoOf(EmptyOptions).s9 = function () {
return this.l9_1;
};
protoOf(EmptyOptions).s9 = function (_set____db54di) {
protoOf(EmptyOptions).t9 = function (_set____db54di) {
this.m9_1 = _set____db54di;
};
protoOf(EmptyOptions).t9 = function () {
protoOf(EmptyOptions).u9 = function () {
return this.m9_1;
};
protoOf(EmptyOptions).u9 = function (_set____db54di) {
this.n9_1 = _set____db54di;
};
protoOf(EmptyOptions).v9 = function () {
return this.n9_1;
};
function DispatcherSnapshot(state, syncQueue, asyncQueue, localSnapshot, remoteSnapshot, timerSnapshot) {

@@ -912,39 +910,39 @@ this.state = state;

}
protoOf(DispatcherSnapshot).f9 = function () {
protoOf(DispatcherSnapshot).e9 = function () {
return this.state;
};
protoOf(DispatcherSnapshot).g9 = function () {
protoOf(DispatcherSnapshot).f9 = function () {
return this.syncQueue;
};
protoOf(DispatcherSnapshot).h9 = function () {
protoOf(DispatcherSnapshot).g9 = function () {
return this.asyncQueue;
};
protoOf(DispatcherSnapshot).w9 = function () {
protoOf(DispatcherSnapshot).v9 = function () {
return this.localSnapshot;
};
protoOf(DispatcherSnapshot).x9 = function () {
protoOf(DispatcherSnapshot).w9 = function () {
return this.remoteSnapshot;
};
protoOf(DispatcherSnapshot).y9 = function () {
protoOf(DispatcherSnapshot).x9 = function () {
return this.timerSnapshot;
};
protoOf(DispatcherSnapshot).c7 = function () {
protoOf(DispatcherSnapshot).b7 = function () {
return this.state;
};
protoOf(DispatcherSnapshot).d7 = function () {
protoOf(DispatcherSnapshot).c7 = function () {
return this.syncQueue;
};
protoOf(DispatcherSnapshot).o7 = function () {
protoOf(DispatcherSnapshot).n7 = function () {
return this.asyncQueue;
};
protoOf(DispatcherSnapshot).z9 = function () {
protoOf(DispatcherSnapshot).y9 = function () {
return this.localSnapshot;
};
protoOf(DispatcherSnapshot).aa = function () {
protoOf(DispatcherSnapshot).z9 = function () {
return this.remoteSnapshot;
};
protoOf(DispatcherSnapshot).ba = function () {
protoOf(DispatcherSnapshot).aa = function () {
return this.timerSnapshot;
};
protoOf(DispatcherSnapshot).ca = function (state, syncQueue, asyncQueue, localSnapshot, remoteSnapshot, timerSnapshot) {
protoOf(DispatcherSnapshot).ba = function (state, syncQueue, asyncQueue, localSnapshot, remoteSnapshot, timerSnapshot) {
return new DispatcherSnapshot(state, syncQueue, asyncQueue, localSnapshot, remoteSnapshot, timerSnapshot);

@@ -959,3 +957,3 @@ };

timerSnapshot = timerSnapshot === VOID ? this.timerSnapshot : timerSnapshot;
return this.ca(state, syncQueue, asyncQueue, localSnapshot, remoteSnapshot, timerSnapshot);
return this.ba(state, syncQueue, asyncQueue, localSnapshot, remoteSnapshot, timerSnapshot);
};

@@ -1049,11 +1047,15 @@ protoOf(DispatcherSnapshot).toString = function () {

}
function BaseTrace(spanName, durationMs) {
function BaseTrace(spanName, startTimeMs, endTimeMs) {
this.spanName = spanName;
this.durationMs = durationMs;
this.startTimeMs = startTimeMs;
this.endTimeMs = endTimeMs;
}
protoOf(BaseTrace).fa = function () {
protoOf(BaseTrace).ea = function () {
return this.spanName;
};
protoOf(BaseTrace).fa = function () {
return this.startTimeMs;
};
protoOf(BaseTrace).ga = function () {
return this.durationMs;
return this.endTimeMs;
};

@@ -1065,3 +1067,3 @@ function ErrorInfo(message, origin, version) {

}
protoOf(ErrorInfo).r5 = function () {
protoOf(ErrorInfo).q5 = function () {
return this.message;

@@ -1084,3 +1086,3 @@ };

function logRuntimeTrace(delegate, span, isRemote, intent, eventCount) {
delegate.logRuntimeTrace(new RuntimeTrace(span.x8_1, span.c9().toString(), intent, getRuntimeTarget(isRemote), eventCount));
delegate.logRuntimeTrace(new RuntimeTrace(span.w8_1, span.x8_1, span.y8_1, intent, getRuntimeTarget(isRemote), eventCount));
}

@@ -1093,4 +1095,4 @@ function logRuntimeError(delegate, message, isRemote, version) {

}
function RuntimeTrace(spanName, durationMs, intent, target, eventCount) {
BaseTrace.call(this, spanName, durationMs);
function RuntimeTrace(spanName, startTimeMs, endTimeMs, intent, target, eventCount) {
BaseTrace.call(this, spanName, startTimeMs, endTimeMs);
this.intent = intent;

@@ -1128,24 +1130,24 @@ this.target = target;

function NiceLogger(logger) {
this.h7_1 = logger;
this.g7_1 = logger;
}
protoOf(NiceLogger).t8 = function (messages) {
protoOf(NiceLogger).s8 = function (messages) {
// Inline function 'kotlin.arrayOf' call
// Inline function 'kotlin.js.unsafeCast' call
// Inline function 'kotlin.js.asDynamic' call
var tmp$ret$2 = arrayConcat([[this.h7_1.tag()], messages]);
this.h7_1.error(tmp$ret$2);
var tmp$ret$2 = arrayConcat([[this.g7_1.tag()], messages]);
this.g7_1.error(tmp$ret$2);
};
protoOf(NiceLogger).j9 = function (messages) {
protoOf(NiceLogger).i9 = function (messages) {
// Inline function 'kotlin.arrayOf' call
// Inline function 'kotlin.js.unsafeCast' call
// Inline function 'kotlin.js.asDynamic' call
var tmp$ret$2 = arrayConcat([[this.h7_1.tag()], messages]);
this.h7_1.warn(tmp$ret$2);
var tmp$ret$2 = arrayConcat([[this.g7_1.tag()], messages]);
this.g7_1.warn(tmp$ret$2);
};
protoOf(NiceLogger).i7 = function (messages) {
protoOf(NiceLogger).h7 = function (messages) {
// Inline function 'kotlin.arrayOf' call
// Inline function 'kotlin.js.unsafeCast' call
// Inline function 'kotlin.js.asDynamic' call
var tmp$ret$2 = arrayConcat([[this.h7_1.tag()], messages]);
this.h7_1.debug(tmp$ret$2);
var tmp$ret$2 = arrayConcat([[this.g7_1.tag()], messages]);
this.g7_1.debug(tmp$ret$2);
};

@@ -1168,3 +1170,3 @@ function NoOpLogger() {

}
protoOf(IntervalEventDeduper).d9 = function (events) {
protoOf(IntervalEventDeduper).c9 = function (events) {
// Inline function 'kotlin.collections.partition' call

@@ -1185,4 +1187,4 @@ var first = ArrayList_init_$Create$();

var tmp0_container = new Pair(first, second);
var intervalEvents = tmp0_container.c7();
var nonIntervalEvents = tmp0_container.d7();
var intervalEvents = tmp0_container.b7();
var nonIntervalEvents = tmp0_container.c7();
// Inline function 'kotlin.collections.distinctBy' call

@@ -1220,3 +1222,3 @@ var set = HashSet_init_$Create$();

}
protoOf(LocalEventsDeduper).d9 = function (events) {
protoOf(LocalEventsDeduper).c9 = function (events) {
var tmp;

@@ -1241,10 +1243,10 @@ if (this.ta_1()) {

// Inline function 'kotlin.collections.isNotEmpty' call
if (!results.b7_1.t()) {
if (!results.a7_1.t()) {
// Inline function 'kotlin.arrayOf' call
// Inline function 'kotlin.js.unsafeCast' call
// Inline function 'kotlin.js.asDynamic' call
var tmp$ret$5 = ['Dropping ' + results.b7_1.q() + ' local events', results.b7_1];
this.ua_1.i7([tmp$ret$5]);
var tmp$ret$5 = ['Dropping ' + results.a7_1.q() + ' local events', results.a7_1];
this.ua_1.h7([tmp$ret$5]);
}
tmp = results.a7_1;
tmp = results.z6_1;
}

@@ -1263,6 +1265,6 @@ return tmp;

};
protoOf(TimerDefinition).c7 = function () {
protoOf(TimerDefinition).b7 = function () {
return this.id;
};
protoOf(TimerDefinition).d7 = function () {
protoOf(TimerDefinition).c7 = function () {
return this.duration;

@@ -1299,15 +1301,15 @@ };

function Span(name, start) {
this.x8_1 = name;
this.y8_1 = start;
this.z8_1 = new Long(0, 0);
this.w8_1 = name;
this.x8_1 = start;
this.y8_1 = 0.0;
}
protoOf(Span).a9 = function () {
this.z8_1 = epochMillis();
protoOf(Span).z8 = function () {
this.y8_1 = epochMillis();
};
protoOf(Span).c9 = function () {
return this.z8_1.m5(this.y8_1);
protoOf(Span).b9 = function () {
return this.y8_1 - this.x8_1;
};
function Tracer() {
}
protoOf(Tracer).s8 = function (name) {
protoOf(Tracer).r8 = function (name) {
return new Span(name, epochMillis());

@@ -1334,3 +1336,3 @@ };

};
protoOf(JsRequestBuilderAdapter).r8 = function (state, events) {
protoOf(JsRequestBuilderAdapter).q8 = function (state, events) {
return this.yb((!(state == null) ? !(state == null) : false) ? state : THROW_CCE(), events);

@@ -1369,3 +1371,3 @@ };

// Inline function 'net.devvit.JsonStateOperations.merge.<anonymous>' call
result[element.a7_1] = element.b7_1;
result[element.z6_1] = element.a7_1;
}

@@ -1377,3 +1379,3 @@ // Inline function 'kotlin.collections.forEach' call

// Inline function 'net.devvit.JsonStateOperations.merge.<anonymous>' call
result[element_0.a7_1] = element_0.b7_1;
result[element_0.z6_1] = element_0.a7_1;
}

@@ -1383,3 +1385,3 @@ return result;

function epochMillis() {
return numberToLong((new Date()).getTime());
return (new Date()).getTime();
}

@@ -1390,25 +1392,25 @@ //region block: post-declaration

defineProp(protoOf(DispatcherImpl), 'state', function () {
return this.f9();
return this.e9();
}, function (value) {
this.e9(value);
this.d9(value);
});
defineProp(protoOf(EmptyOptions), 'logger', function () {
return this.p9();
return this.o9();
}, function (value) {
this.o9(value);
this.n9(value);
});
defineProp(protoOf(EmptyOptions), 'errorHandler', function () {
return this.r9();
return this.q9();
}, function (value) {
this.q9(value);
this.p9(value);
});
defineProp(protoOf(EmptyOptions), 'featureFlags', function () {
return this.t9();
return this.s9();
}, function (value) {
this.s9(value);
this.r9(value);
});
defineProp(protoOf(EmptyOptions), 'performanceAnalyticsDelegate', function () {
return this.v9();
return this.u9();
}, function (value) {
this.u9(value);
this.t9(value);
});

@@ -1427,5 +1429,5 @@ defineProp(protoOf(EventScope), 'name', protoOf(EventScope).x4);

defineProp(protoOf(JsDispatcherImpl), 'state', function () {
return this.f9();
return this.e9();
}, function (value) {
this.e9(value);
this.d9(value);
});

@@ -1432,0 +1434,0 @@ //endregion

{
"name": "@devvit/multiplatform",
"version": "0.0.1-20241119-bd8b7759",
"version": "0.0.1-20241213-bc413934",
"main": "kotlin/ui-shared-shared.mjs",

@@ -5,0 +5,0 @@ "devDependencies": {

Sorry, the diff of this file is too big to display

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc