Function makeQueue

packages/platform-browser/src/Geolocation.ts:76–102

(
  options:
    | PositionOptions & {
      readonly bufferSize?: number | undefined
    }
    | undefined
)

}

const makeQueue = (
  options:
    | PositionOptions & {
      readonly bufferSize?: number | undefined
    }
    | undefined
) =>
  Queue.sliding<Either.Either<GeolocationPosition, GeolocationError>>(options?.bufferSize ?? 16).pipe(
    Effect.tap((queue) =>
      Effect.acquireRelease(
        Effect.sync(() =>
          navigator.geolocation.watchPosition(
            (position) => queue.unsafeOffer(Either.right(position)),
            (cause) => {
              if (cause.code === cause.PERMISSION_DENIED) {
                queue.unsafeOffer(Either.left(new GeolocationError({ reason: "PermissionDenied", cause })))
              } else if (cause.code === cause.TIMEOUT) {
                queue.unsafeOffer(Either.left(new GeolocationError({ reason: "Timeout", cause })))
              }
            },
            options
          )
        ),
        (handleId) => Effect.sync(() => navigator.geolocation.clearWatch(handleId))
      )
    )
  )

/**
 * @since 1.0.0