implement assertElements

Add test for Schedule#onDecision and documentation for scheduling (zio#3346)

* Add test for Schedule#onDecision and documentation for scheduling

* Add documentation to datatypes, remove console functions from ScheduleSpec

* fix mdoc compile issue

specialize ChunkBuilder (zio#3400)

Implement ZRefM (zio#3391)

* implement ZRefM

* fix Scala 2.13 compatibility issue

* address review comments

* implement SubscriptionRef

* make constructor private

* remove managed variant

* remove unused import

Implement ZIO#mapEffect (zio#3404)

* implement mapEffect

* implement mapPartial

Improve TArray's performance (zio#3407)

* Benchmark TArray

* Implement fold and transform via unsafe

* Improve readability

* Implement find via unsafe

* Implement findLast via unsafe

* Implement foldM via unsafe

* Benchmark indexWhere

* Implement transformM via unsafe

* Implement indexWhere via unsafe

* Implement lastIndexOf via unsafe

* Remove duplicated code

* Implement foldM via ZIO.foldLeft

* Remove 0-sized array from benchmark

* Implement reduceOption via unsafe

* Implement findM via foldM

* Help inference via Option.empty

* Implement findM via iterate

* Implement findLastM via iterate

* Remove useless val

* Format the sources

Update sbt-header to 5.6.0 (zio#3411)

Add AssertionM for effectfull assertions (zio#3403)

Add result field to AssertionValue to avoid test reevaluation.
Protect AssertionValue.assertion to avoid test reevaluation.

Use lazy val tryValue = Try(value) to avoid exception reevaluation:
lazy val stores only successful case.

implement launch (zio#3415)

Add alternative combinator to ZSTM (zio#3414)

* Drop duplicated test

* Remove unnecessary .unit calls

* Align the naming

* Write failing tests

* Keep semantically correct orElse tests

* Fix test expectations

* Fix orElse behavior on failures

* Fix orElse behavior on retries

* Reduce flakiness

* Revert orElse changes

* Introduce alternative combinator

* Update docs

* Reduce flakiness

* Make right retry explicit

* Race updater and transaction

* Move left-right recovery test to JVM tests

* Drop E from orElseSucceed

Co-Authored-By: John A. De Goes <[email protected]>

* Rename alternative to orTry

Co-Authored-By: John A. De Goes <[email protected]>

* Revert "Move left-right recovery test to JVM tests"

This reverts commit 19f1162.

* Tag retry test as JVM-only

* Fix compilation issues

* Fix docs

* Improve scaladoc

Co-Authored-By: John A. De Goes <[email protected]>

* Fix doc mistake

Co-authored-by: John A. De Goes <[email protected]>

Update sbt-scalafix to 0.9.15 (zio#3423)

Optimize TQueue (zio#3421)

Update sbt-ci-release to 1.5.3 (zio#3425)

ZIO Test: Support Laws for Capabilities Parameterized on Two Types (zio#3420)

* implement ZLaws2

* use AnyF

Back up Chunk[Boolean] by Chunk.BitChunks (zio#3419)

fix publishing (zio#3433)

WIP: Scala.js upgrade to v1.0.0 (zio#2392) (zio#2479)

* Update to Scala.js 1.0.0-RC2

* fix for passing testJS

* formatting fix

* Merge remote-tracking branch 'upstream/master' into feature/scalajs-1.0.0-RC2

* Merge branch 'master' of https://github.com/zio/zio into feature/scalajs-1.0.0-RC2

* sonatype resolver added for izumi-reflect;
magnolia updated to v0.12.8

Fix Scala.js build (post zio#2479) (zio#3436)

* Fix Scala.js build (post zio#2479)

* Move back to shared/Executor source and add jvm/js/native ExecutorPlatformSpecific trait

* Fix imports causing build failure on 2.13/dotty

Update Magnolia (zio#3432)

* Update Magnolia

There is a bug in Magnolia versions < 0.15 which causes derivation for case classes with default values to fail.
The update should fix it.

* Add scala-reflect % Provided dependency, now required for magnolia & exclude scala-compiler

Co-authored-by: Kai <[email protected]>
Co-authored-by: Kai <[email protected]>

Update nyaya-gen to 0.9.1 (zio#3438)

Remove sonatype public resolver (zio#3434)

Add specialized accessor operations to Chunk (zio#3431)

* Add specialized accessor operations to Chunk

* Generate only non-empty chunks using chunkWithIndex generator

Add ZIO STM blogpost (zio#3443)

generalize (zio#3439)

Update scala-java-time to 2.0.0 (zio#3446)

suspend effects (zio#3444)

Fix Publishing on Master (zio#3437)

* fix publishing

* fix bug

add Scalac logo to the Sponsors section in Readme (zio#3379)

Implement ZIO#service (zio#3422)

* implement getService

* add variants

* rename

Add Diagnostic Code to Has (zio#3377)

* add diagnostic code

* Fix environment composition

* Fix 2.11/dotty

Co-authored-by: ioleo <[email protected]>

Use short forms where it makes sense (zio#3452)

* Use short forms where it makes sense

* One more `none` usage.

Update to izumi-reflect 1.0.0-M1, use izumi-reflect on dotty (zio#3445)

* Update to izumi-reflect-1.0.0-M1, depend on izumi-reflect in dotty

* Use one VersionSpecific file for dotty & scala-2

* Adding type signatures to Mock modules to workaround scala/scala3#8764

error:

```
  [error] -- Error: PureModule.scala:77:86
  [error] 77 |  val static                                           = ZIO.accessM[PureModule](_.get.static)
  [error]    |                                                                                      ^
  [error]    |could not find implicit value for izumi.reflect.Tag[zio.test.mock.module.PureModule.Service]. Did you forget to put on a Tag, TagK or TagKK context bound on one of the parameters in zio.test.mock.module.PureModule.Service? e.g. def x[T: Tag, F[_]: TagK] = ....
  [error]    |I found:
  [error]    |
  [error]    |    {
  [error]    |      izumi.reflect.Tag.apply[zio.test.mock.module.PureModule.Service](classOf[Any]
  [error]    |        ,
  [error]    |      {
  [error]    |        <empty> :izumi.reflect.macrortti.LightTypeTag
  [error]    |      }
  [error]    |      ):izumi.reflect.Tag[zio.test.mock.module.PureModule.Service]
  [error]    |    }
  [error]    |
  [error]    |But method tagFromTagMacro in object Tag does not match type izumi.reflect.Tag[zio.test.mock.module.PureModule.Service].
  [error]    |
  [error]    |The following import might make progress towards fixing the problem:
  [error]    |
  [error]    |  import izumi.reflect.Tag.tagFromTagMacro
```

* add type signature to SpecSpec to workaround error:

```
[error] -- Error: SpecSpec.scala:17:51
[error] 17 |  val layer = ZLayer.succeed(new Module.Service {})
[error]    |                                                   ^
[error]    |could not find implicit value for izumi.reflect.Tag[zio.test.SpecSpec.Module.Service]. Did you forget to put on a Tag, TagK or TagKK context bound on one of the parameters in zio.test.SpecSpec.Module.Service? e.g. def x[T: Tag, F[_]: TagK] = ....
[error]    |I found:
[error]    |
[error]    |    {
[error]    |      izumi.reflect.Tag.apply[zio.test.SpecSpec.Module.Service](classOf[Any],
[error]    |        {
[error]    |          <empty> :izumi.reflect.macrortti.LightTypeTag
[error]    |        }
[error]    |      ):izumi.reflect.Tag[zio.test.SpecSpec.Module.Service]
[error]    |    }
[error]    |
[error]    |But method tagFromTagMacro in object Tag does not match type izumi.reflect.Tag[zio.test.SpecSpec.Module.Service].
[error]    |
[error]    |The following import might make progress towards fixing the problem:
[error]    |
[error]    |  import izumi.reflect.Tag.tagFromTagMacro
```

* Lift `exceptDotty` from HasSpec & ComposedMockSpec (TaggedSpec still won't pass because deriving is not implemented)

* add type signatures to MockSpecUtils, update comments

* Workaround type inference-caused test failures in PolyMockSpec - Any was inferred for `Tag` now, probably maybe because Tag parameter is AnyKind, add workaround

* Fix `@mockable` macro, restrict valid `Tagged` definitions to just izumi.reflect.Tag

* sbt fix

fix type signature (zio#3455)

Update util-core to 20.4.1 (zio#3457)

generalize type signature (zio#3460)

doc(test_effects) : add aspect ignore (zio#3462)

upgrade monix version (zio#3467)

Implement ZManaged#flattenM (zio#3464)

* implement flattenM

* format

* fix Scaladoc

reorder type parameters (zio#3463)

Implement ZManaged#release (zio#3466)

* implement ZManaged#release

* rename

Use ChunkBuilder more prominently in Chunk (zio#3453)

* make Chunk use ChunkBuilder

* fix lint failure

* consistent parenthesis use

* use parens for Chunkbuilder#make

* followup

* retrigger ci

Update reactor-core to 3.3.5.RELEASE (zio#3472)

Update magnolia to 0.16.0 (zio#3473)

Update nyaya-gen to 0.9.2 (zio#3474)

added blog to list (zio#3471)

* updated blog for RC18 + http4s .21.x

* added new blog to resource page

Co-authored-by: Pierre Ricadat <[email protected]>

Add zio-easymock to libraries with zio support list (zio#3481)

Add ZIO#filterNot and ZSTM#filterNot (zio#3477)

* Add ZIO#filterNot and ZSTM#filterNot

* Fix typos

implement assertElements and assertElements

Author: marktoujiline

README.md

@@ -31,6 +31,10 @@ To learn more about ZIO, see the following references:
 
 # Sponsors
 
+[![Scalac][Image-Scalac]][Link-Scalac]
+
+[Scalac][Link-Scalac] sponsors ZIO Hackathons and contributes work to multiple projects in ZIO ecosystem.
+
 [![Septimal Mind][Image-SeptimalMind]][Link-SeptimalMind]
 
 [Septimal Mind][Link-SeptimalMind] sponsors work on ZIO Tracing and continuous maintenance.
@@ -39,6 +43,7 @@ To learn more about ZIO, see the following references:
 
 [SoftwareMill][Link-SoftwareMill] generously provides ZIO with paid-for CircleCI build infrastructure.
 
+
 ---
 
 # [Learn More on the ZIO Homepage](https://zio.dev/)
@@ -68,6 +73,7 @@ Copyright 2017 - 2020 John A. De Goes and the ZIO Contributors. All rights reser
 [Link-SonatypeReleases]: https://oss.sonatype.org/content/repositories/releases/dev/zio/zio_2.12/ "Sonatype Releases"
 [Link-SonatypeSnapshots]: https://oss.sonatype.org/content/repositories/snapshots/dev/zio/zio_2.12/ "Sonatype Snapshots"
 [Link-Circle]: https://circleci.com/gh/zio/zio "circleci"
+[Link-Scalac]: https://scalac.io "Scalac"
 [Link-SoftwareMill]: https://softwaremill.com "SoftwareMill"
 [Link-SeptimalMind]: https://7mind.io "Septimal Mind"
 [Link-Discord]: https://discord.gg/2ccFBr4 "Discord"
@@ -82,5 +88,6 @@ Copyright 2017 - 2020 John A. De Goes and the ZIO Contributors. All rights reser
 [Badge-Discord]: https://img.shields.io/discord/629491597070827530?logo=discord "chat on discord"
 [Badge-Twitter]: https://img.shields.io/twitter/follow/zioscala.svg?style=plastic&label=follow&logo=twitter
 
+[Image-Scalac]: ./website/static/img/scalac.svg "Scalac"
 [Image-SoftwareMill]: ./website/static/img/softwaremill.svg "SoftwareMill"
 [Image-SeptimalMind]: ./website/static/img/septimal_mind.svg "Septimal Mind"

benchmarks/src/main/scala/zio/FiberRefBenchmarks.scala

@@ -53,7 +53,7 @@ class FiberRefBenchmarks {
     for {
       fiberRefs <- ZIO.foreach(1.to(n))(i => FiberRef.make(i))
       _         <- ZIO.foreach_(1.to(n))(_ => ZIO.yieldNow)
-      values    <- ZIO.collectAllPar(fiberRefs.map(_.get))
+      values    <- ZIO.foreachPar(fiberRefs)(_.get)
       _         <- verify(values == 1.to(n))(s"Got $values")
     } yield ()
   }

benchmarks/src/main/scala/zio/ParSequenceBenchmark.scala

@@ -57,22 +57,22 @@ class ParSequenceBenchmark {
     result.runSyncUnsafe()
   }
   @Benchmark
-  def monixGather(): Long = {
+  def monixParSequence(): Long = {
     val tasks  = (0 until count).map(_ => MTask.eval(1)).toList
-    val result = MTask.gather(tasks).map(_.sum.toLong)
+    val result = MTask.parSequence(tasks).map(_.sum.toLong)
     result.runSyncUnsafe()
   }
   @Benchmark
-  def monixGatherUnordered(): Long = {
+  def monixParSequenceUnordered(): Long = {
     val tasks  = (0 until count).map(_ => MTask.eval(1)).toList
-    val result = MTask.gatherUnordered(tasks).map(_.sum.toLong)
+    val result = MTask.parSequenceUnordered(tasks).map(_.sum.toLong)
     result.runSyncUnsafe()
   }
 
   @Benchmark
-  def monixGatherN(): Long = {
+  def monixParSequenceN(): Long = {
     val tasks  = (0 until count).map(_ => MTask.eval(1)).toList
-    val result = MTask.gatherN(parallelism)(tasks).map(_.sum.toLong)
+    val result = MTask.parSequenceN(parallelism)(tasks).map(_.sum.toLong)
     result.runSyncUnsafe()
   }
 

benchmarks/src/main/scala/zio/QueueSequentialBenchmark.scala

@@ -50,8 +50,8 @@ class QueueSequentialBenchmark {
       else task.flatMap(_ => repeat(task, max - 1))
 
     val io = for {
-      _ <- repeat(zioQ.offer(0).map(_ => ()), totalSize)
-      _ <- repeat(zioQ.take.map(_ => ()), totalSize)
+      _ <- repeat(zioQ.offer(0).unit, totalSize)
+      _ <- repeat(zioQ.take.unit, totalSize)
     } yield 0
 
     unsafeRun(io)

benchmarks/src/main/scala/zio/chunks/MixedChunkBenchmarks.scala

@@ -48,6 +48,10 @@ class MixedChunkBenchmarks {
   @Benchmark
   def fold(): Int = chunk.fold(0)(_ + _)
 
+  @Benchmark
+  def filterM(): Chunk[Int] =
+    IOBenchmarks.unsafeRun(chunk.filterM[Any, Nothing](n => ZIO.succeed(n % 2 == 0)))
+
   @Benchmark
   def map(): Chunk[Int] = chunk.map(_ * 2)
 
@@ -61,6 +65,7 @@ class MixedChunkBenchmarks {
   def mapM(): UIO[Unit] = chunk.mapM_(_ => ZIO.unit)
 
   @Benchmark
-  def foldM(): UIO[Int] = chunk.foldM(0)((s, a) => ZIO.succeed(s + a))
+  def foldM(): Int =
+    IOBenchmarks.unsafeRun(chunk.foldM[Any, Nothing, Int](0)((s, a) => ZIO.succeed(s + a)))
 
 }

benchmarks/src/main/scala/zio/stm/TArrayOpsBenchmarks.scala

@@ -0,0 +1,86 @@
+package zio.stm
+
+import java.util.concurrent.TimeUnit
+
+import org.openjdk.jmh.annotations._
+
+import zio._
+
+@State(Scope.Thread)
+@BenchmarkMode(Array(Mode.Throughput))
+@OutputTimeUnit(TimeUnit.SECONDS)
+@Measurement(iterations = 15, timeUnit = TimeUnit.SECONDS, time = 3)
+@Warmup(iterations = 15, timeUnit = TimeUnit.SECONDS, time = 3)
+@Fork(1)
+class TArrayOpsBenchmarks {
+  import IOBenchmarks.unsafeRun
+
+  @Param(Array("10", "100", "1000", "10000", "100000"))
+  var size: Int = _
+
+  private var idx: Int           = _
+  private var array: TArray[Int] = _
+
+  // used to ammortize the relative cost of unsafeRun
+  // compared to benchmarked operations
+  private val calls = List.fill(500)(false)
+
+  @Setup(Level.Trial)
+  def setup(): Unit = {
+    val data = (1 to size).toList
+    idx = size / 2
+    array = unsafeRun(TArray.fromIterable(data).commit)
+  }
+
+  @Benchmark
+  def lookup(): Unit =
+    unsafeRun(ZIO.foreach_(calls)(_ => array(idx).commit))
+
+  @Benchmark
+  def find(): Option[Int] =
+    unsafeRun(array.find(_ == size).commit)
+
+  @Benchmark
+  def findM(): Option[Int] =
+    unsafeRun(array.findM(a => STM.succeedNow(a == size)).commit)
+
+  @Benchmark
+  def fold(): Int =
+    unsafeRun(array.fold(0)(_ + _).commit)
+
+  @Benchmark
+  def foldM(): Int =
+    unsafeRun(array.foldM(0)((acc, e) => STM.succeedNow(acc + e)).commit)
+
+  @Benchmark
+  def indexWhere(): Int =
+    unsafeRun(array.indexWhere(_ == size).commit)
+
+  @Benchmark
+  def indexWhereM(): Int =
+    unsafeRun(array.indexWhereM(a => STM.succeedNow(a == size)).commit)
+
+  @Benchmark
+  def reduceOption(): Option[Int] =
+    unsafeRun(array.reduceOption(_ + _).commit)
+
+  @Benchmark
+  def reduceOptionM(): Option[Int] =
+    unsafeRun(array.reduceOptionM((a, b) => STM.succeedNow(a + b)).commit)
+
+  @Benchmark
+  def transform(): Unit =
+    unsafeRun(array.transform(_ + 1).commit)
+
+  @Benchmark
+  def transformM(): Unit =
+    unsafeRun(array.transformM(i => STM.succeedNow(i + 1)).commit)
+
+  @Benchmark
+  def update(): Unit =
+    unsafeRun(ZIO.foreach_(calls)(_ => array.update(idx, _ + 1).commit))
+
+  @Benchmark
+  def updateM(): Unit =
+    unsafeRun(ZIO.foreach_(calls)(_ => array.updateM(idx, i => STM.succeedNow(i + 1)).commit))
+}

build.sbt

@@ -206,6 +206,11 @@ lazy val test = crossProject(JSPlatform, JVMPlatform)
   .settings(crossProjectSettings)
   .settings(macroDefinitionSettings)
   .settings(macroExpansionSettings)
+  .settings(
+    libraryDependencies ++= Seq(
+      ("org.portable-scala" %%% "portable-scala-reflect" % "1.0.0").withDottyCompat(scalaVersion.value)
+    )
+  )
 
 lazy val testJVM = test.jvm.settings(dottySettings)
 lazy val testJS  = test.js
@@ -229,10 +234,11 @@ lazy val testMagnolia = crossProject(JVMPlatform, JSPlatform)
   .in(file("test-magnolia"))
   .dependsOn(test)
   .settings(stdSettings("zio-test-magnolia"))
+  .settings(macroDefinitionSettings)
   .settings(
     crossScalaVersions --= Seq("2.11.12", dottyVersion),
     scalacOptions += "-language:experimental.macros",
-    libraryDependencies += "com.propensive" %%% "magnolia" % "0.12.6"
+    libraryDependencies += ("com.propensive" %%% "magnolia" % "0.16.0").exclude("org.scala-lang", "scala-compiler")
   )
 
 lazy val testMagnoliaJVM = testMagnolia.jvm
@@ -273,13 +279,8 @@ lazy val testRunner = crossProject(JVMPlatform, JSPlatform)
   .in(file("test-sbt"))
   .settings(stdSettings("zio-test-sbt"))
   .settings(crossProjectSettings)
-  .settings(
-    libraryDependencies ++= Seq(
-      "org.portable-scala" %%% "portable-scala-reflect" % "1.0.0"
-    ),
-    mainClass in (Test, run) := Some("zio.test.sbt.TestMain")
-  )
-  .jsSettings(libraryDependencies ++= Seq("org.scala-js" %% "scalajs-test-interface" % "0.6.32"))
+  .settings(mainClass in (Test, run) := Some("zio.test.sbt.TestMain"))
+  .jsSettings(libraryDependencies ++= Seq("org.scala-js" %% "scalajs-test-interface" % "1.0.1"))
   .jvmSettings(libraryDependencies ++= Seq("org.scala-sbt" % "test-interface" % "1.0"))
   .dependsOn(core)
   .dependsOn(test)
@@ -326,18 +327,18 @@ lazy val benchmarks = project.module
       Seq(
         "co.fs2"                    %% "fs2-core"      % "2.3.0",
         "com.google.code.findbugs"  % "jsr305"         % "3.0.2",
-        "com.twitter"               %% "util-core"     % "20.4.0",
+        "com.twitter"               %% "util-core"     % "20.4.1",
         "com.typesafe.akka"         %% "akka-stream"   % "2.6.4",
-        "io.monix"                  %% "monix"         % "3.1.0",
-        "io.projectreactor"         % "reactor-core"   % "3.3.4.RELEASE",
+        "io.monix"                  %% "monix"         % "3.2.0",
+        "io.projectreactor"         % "reactor-core"   % "3.3.5.RELEASE",
         "io.reactivex.rxjava2"      % "rxjava"         % "2.2.19",
         "org.ow2.asm"               % "asm"            % "8.0.1",
         "org.scala-lang"            % "scala-compiler" % scalaVersion.value % Provided,
         "org.scala-lang"            % "scala-reflect"  % scalaVersion.value,
         "org.typelevel"             %% "cats-effect"   % "2.1.3",
         "org.scalacheck"            %% "scalacheck"    % "1.14.3",
         "hedgehog"                  %% "hedgehog-core" % "0.1.0",
-        "com.github.japgolly.nyaya" %% "nyaya-gen"     % "0.9.0"
+        "com.github.japgolly.nyaya" %% "nyaya-gen"     % "0.9.2"
       ),
     unusedCompileDependenciesFilter -= libraryDependencies.value
       .map(moduleid => moduleFilter(organization = moduleid.organization, name = moduleid.name))