git » sdk » main » tree

[main] / borogove / AsyncLock.hx 

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
package borogove;

import thenshim.Promise;

class AsyncLock {
	private var p: Promise<Any>;

	public function new() {
		p = Promise.resolve(null);
	}

	public function run<T>(fn: () -> Promise<T>): Promise<T> {
		final next = p.then(_ -> fn());
		p = next.then(_->{}, _->{}); // prevent chain break
		return next;
	}
}