Skip to content

Commit

Permalink
fable-standalone 1.1
Browse files Browse the repository at this point in the history
  • Loading branch information
alfonsogarciacaro committed May 10, 2019
1 parent a45fc0f commit b51d644
Show file tree
Hide file tree
Showing 5 changed files with 15 additions and 10 deletions.
4 changes: 4 additions & 0 deletions src/fable-standalone/RELEASE_NOTES.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,7 @@
### 1.1.0

* Update bundle and Worker dependencies

### 1.0.4

* Fixed optimized patterns
Expand Down
2 changes: 1 addition & 1 deletion src/fable-standalone/package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "fable-standalone",
"version": "1.0.4",
"version": "1.1.0",
"main": "dist/bundle.min.js",
"description": "Fable compiler",
"keywords": [
Expand Down
12 changes: 6 additions & 6 deletions src/fable-standalone/src/Worker/Shared.fs
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ open System
open System.Collections.Generic
open Fable.Core
open Fable.Core.JsInterop
open Fable.Import
open Thoth.Json

type WorkerRequest =
Expand Down Expand Up @@ -36,7 +35,7 @@ type WorkerAnswer =
static member Decoder =
Decode.Auto.generateDecoder<WorkerAnswer>()

type ObservableWorker<'InMsg>(worker: obj, decoder: Decode.Decoder<'InMsg>, ?name: string) =
type ObservableWorker<'InMsg>(worker: obj, decoder: Decoder<'InMsg>, ?name: string) =
let name = defaultArg name "FABLE WORKER"
let listeners = new Dictionary<Guid, IObserver<'InMsg>>()
do worker?addEventListener("message", fun ev ->
Expand All @@ -49,11 +48,12 @@ type ObservableWorker<'InMsg>(worker: obj, decoder: Decode.Decoder<'InMsg>, ?nam
listener.OnNext(msg)
| Error err -> JS.console.error("[" + name + "] Cannot decode:", err)
| _ -> ())
member __.Worker = worker
member __.HasListeners =
listeners.Count > 0
member __.Post msg =
worker?postMessage(Encode.Auto.toString(0, msg))
member this.PostAndAwaitResponse(msg, picker) =
member inline this.Post(msg: 'OutMsg): unit =
this.Worker?postMessage(Encode.Auto.toString(0, msg))
member inline this.PostAndAwaitResponse(msg: 'OutMsg, picker: 'InMsg -> 'Res option): Async<'Res> =
Async.FromContinuations(fun (cont, err, cancel) ->
let mutable disp = Unchecked.defaultof<IDisposable>
disp <- this |> Observable.subscribe(fun msg ->
Expand All @@ -62,7 +62,7 @@ type ObservableWorker<'InMsg>(worker: obj, decoder: Decode.Decoder<'InMsg>, ?nam
disp.Dispose()
cont res
| None -> ())
worker?postMessage(Encode.Auto.toString(0, msg))
this.Worker?postMessage(Encode.Auto.toString(0, msg))
)
member __.Subscribe obs =
let id = Guid.NewGuid()
Expand Down
1 change: 0 additions & 1 deletion src/fable-standalone/src/Worker/Worker.fs
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ module Fable.WebWorker.Main

open Fable.Core
open Fable.Core.JsInterop
open Fable.Import
open Fable.Standalone
open Fable.WebWorker

Expand Down
6 changes: 4 additions & 2 deletions src/fable-standalone/src/Worker/Worker.fsproj
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>netstandard2.0</TargetFramework>
<DisableImplicitFSharpCoreReference>true</DisableImplicitFSharpCoreReference>
</PropertyGroup>
<ItemGroup>
<Compile Include="../Interfaces.fs" />
Expand All @@ -10,7 +11,8 @@
<Compile Include="Worker.fs" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Fable.Core" Version="2.0.3" />
<PackageReference Include="Thoth.Json" Version="2.5.0" />
<PackageReference Include="FSharp.Core" Version="4.6.2" />
<PackageReference Include="Fable.Core" Version="3.0.0" />
<PackageReference Include="Thoth.Json" Version="3.1.0" />
</ItemGroup>
</Project>

0 comments on commit b51d644

Please sign in to comment.