171 lines
		
	
	
		
			6.4 KiB
		
	
	
	
		
			Haxe
		
	
	
	
	
	
			
		
		
	
	
			171 lines
		
	
	
		
			6.4 KiB
		
	
	
	
		
			Haxe
		
	
	
	
	
	
| /*
 | |
|  * Copyright (C)2014-2020 Haxe Foundation
 | |
|  *
 | |
|  * Permission is hereby granted, free of charge, to any person obtaining a
 | |
|  * copy of this software and associated documentation files (the "Software"),
 | |
|  * to deal in the Software without restriction, including without limitation
 | |
|  * the rights to use, copy, modify, merge, publish, distribute, sublicense,
 | |
|  * and/or sell copies of the Software, and to permit persons to whom the
 | |
|  * Software is furnished to do so, subject to the following conditions:
 | |
|  *
 | |
|  * The above copyright notice and this permission notice shall be included in
 | |
|  * all copies or substantial portions of the Software.
 | |
|  *
 | |
|  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 | |
|  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 | |
|  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 | |
|  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 | |
|  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
 | |
|  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
 | |
|  * DEALINGS IN THE SOFTWARE.
 | |
|  */
 | |
| 
 | |
| package js.node.domain;
 | |
| 
 | |
| import haxe.Constraints.Function;
 | |
| import js.node.Timers.Timeout;
 | |
| import js.node.events.EventEmitter;
 | |
| 
 | |
| /**
 | |
| 	Enumeration of events emitted by `Domain` objects.
 | |
| **/
 | |
| @:deprecated
 | |
| @:enum abstract DomainEvent<T:Function>(Event<T>) to Event<T> {
 | |
| 	var Error:DomainEvent<DomainError->Void> = "error";
 | |
| 	var Dispose:DomainEvent<Void->Void> = "dispose";
 | |
| }
 | |
| 
 | |
| /**
 | |
| 	Any time an Error object is routed through a domain, a few extra fields are added to it.
 | |
| **/
 | |
| @:deprecated
 | |
| typedef DomainError = {
 | |
| 	/**
 | |
| 		The domain that first handled the error.
 | |
| 	**/
 | |
| 	var domain:Domain;
 | |
| 
 | |
| 	/**
 | |
| 		The event emitter that emitted an 'error' event with the error object.
 | |
| 	**/
 | |
| 	var domainEmitter:IEventEmitter;
 | |
| 
 | |
| 	/**
 | |
| 		The callback function which was bound to the domain, and passed an error as its first argument.
 | |
| 	**/
 | |
| 	var domainBound:Function;
 | |
| 
 | |
| 	/**
 | |
| 		A boolean indicating whether the error was thrown, emitted, or passed to a bound callback function.
 | |
| 	**/
 | |
| 	var domainThrown:Bool;
 | |
| }
 | |
| 
 | |
| /**
 | |
| 	The Domain class encapsulates the functionality of routing errors
 | |
| 	and uncaught exceptions to the active Domain object.
 | |
| **/
 | |
| @:deprecated
 | |
| extern class Domain extends EventEmitter<Domain> {
 | |
| 	/**
 | |
| 		Run the supplied function in the context of the domain, implicitly binding all event emitters, timers,
 | |
| 		and lowlevel requests that are created in that context.
 | |
| 
 | |
| 		This is the most basic way to use a domain.
 | |
| 	**/
 | |
| 	function run(fn:Void->Void):Void;
 | |
| 
 | |
| 	/**
 | |
| 		An array of timers and event emitters that have been explicitly added to the domain.
 | |
| 	**/
 | |
| 	var members(default, null):Array<haxe.extern.EitherType<IEventEmitter, Timeout>>;
 | |
| 
 | |
| 	/**
 | |
| 		Explicitly adds an `emitter` to the domain.
 | |
| 
 | |
| 		If any event handlers called by the emitter throw an error, or if the emitter emits an error event,
 | |
| 		it will be routed to the domain's error event, just like with implicit binding.
 | |
| 
 | |
| 		This also works with timers that are returned from `setInterval` and `setTimeout`.
 | |
| 		If their callback function throws, it will be caught by the domain 'error' handler.
 | |
| 
 | |
| 		If the Timer or EventEmitter was already bound to a domain, it is removed from that one,
 | |
| 		and bound to this one instead.
 | |
| 	**/
 | |
| 	@:overload(function(emitter:Timeout):Void {})
 | |
| 	function add(emitter:IEventEmitter):Void;
 | |
| 
 | |
| 	/**
 | |
| 		The opposite of `add`. Removes domain handling from the specified emitter.
 | |
| 	**/
 | |
| 	@:overload(function(emitter:Timeout):Void {})
 | |
| 	function remove(emitter:IEventEmitter):Void;
 | |
| 
 | |
| 	/**
 | |
| 		The returned function will be a wrapper around the supplied `callback` function.
 | |
| 		When the returned function is called, any errors that are thrown will be routed to the domain's error event.
 | |
| 	**/
 | |
| 	function bind<T:Function>(callback:T):T;
 | |
| 
 | |
| 	/**
 | |
| 		This method is almost identical to `bind`. However, in addition to catching thrown errors, it will also
 | |
| 		intercept `Error` objects sent as the first argument to the function.
 | |
| 
 | |
| 		In this way, the common if (er != null) return callback(er); pattern
 | |
| 		can be replaced with a single error handler in a single place.
 | |
| 	**/
 | |
| 	function intercept<T:Function>(callback:T):T;
 | |
| 
 | |
| 	/**
 | |
| 		The `enter` method is plumbing used by the `run`, `bind`, and `intercept` methods to set the active domain.
 | |
| 
 | |
| 		It sets `domain.active` and `process.domain` to the domain, and implicitly pushes the domain onto
 | |
| 		the domain stack managed by the domain module (see `exit` for details on the domain stack).
 | |
| 
 | |
| 		The call to `enter` delimits the beginning of a chain of asynchronous calls and I/O operations bound to a domain.
 | |
| 
 | |
| 		Calling `enter` changes only the active domain, and does not alter the domain itself.
 | |
| 		Enter and exit can be called an arbitrary number of times on a single domain.
 | |
| 
 | |
| 		If the domain on which `enter` is called has been disposed, `enter` will return without setting the domain.
 | |
| 	**/
 | |
| 	function enter():Void;
 | |
| 
 | |
| 	/**
 | |
| 		The `exit` method exits the current domain, popping it off the domain stack.
 | |
| 
 | |
| 		Any time execution is going to switch to the context of a different chain of asynchronous calls,
 | |
| 		it's important to ensure that the current domain is exited. The call to `exit` delimits either the end of
 | |
| 		or an interruption to the chain of asynchronous calls and I/O operations bound to a domain.
 | |
| 
 | |
| 		If there are multiple, nested domains bound to the current execution context,
 | |
| 		`exit` will exit any domains nested within this domain.
 | |
| 
 | |
| 		Calling `exit` changes only the active domain, and does not alter the domain itself.
 | |
| 		Enter and exit can be called an arbitrary number of times on a single domain.
 | |
| 
 | |
| 		If the domain on which `exit` is called has been disposed, `exit` will return without exiting the domain.
 | |
| 	**/
 | |
| 	function exit():Void;
 | |
| 
 | |
| 	/**
 | |
| 		The `dispose` method destroys a domain, and makes a best effort attempt
 | |
| 		to clean up any and all IO that is associated with the domain.
 | |
| 
 | |
| 		Streams are aborted, ended, closed, and/or destroyed. Timers are cleared.
 | |
| 		Explicitly bound callbacks are no longer called.
 | |
| 
 | |
| 		Any error events that are raised as a result of this are ignored.
 | |
| 
 | |
| 		The intention of calling `dispose` is generally to prevent cascading errors when a critical part of
 | |
| 		the Domain context is found to be in an error state.
 | |
| 
 | |
| 		Once the domain is disposed the 'dispose' event will emit.
 | |
| 
 | |
| 		Note that IO might still be performed. However, to the highest degree possible, once a domain is disposed,
 | |
| 		further errors from the emitters in that set will be ignored. So, even if some remaining actions are still
 | |
| 		in flight, Node.js will not communicate further about them.
 | |
| 	**/
 | |
| 	function dispose():Void;
 | |
| }
 |